offsets = (HashMap<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap) | offsets = (Map<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap) | (HashMap<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap) | (Map<KafkaTopicPartition,Long>)pendingOffsetsToCommit.remove(posInMap) | flink | 085d4db849b9c659ba6bb2c7d66a04debeb048c4 | org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | | | v0 | pendingOffsetsToCommit.remove(posInMap) |
---|
| | v0 | pendingOffsetsToCommit.remove(posInMap) |
---|
| AssignedTo | True |