Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1437#discussion_r46837302
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@ -222,18 +219,18 @@
/** The committer that persists the committed offsets */
private transient OffsetHandler offsetHandler;
- /** The partitions actually handled by this consumer */
- private transient List<TopicPartition> subscribedPartitions;
+ /** The partitions actually handled by this consumer at runtime */
+ private transient List<KafkaTopicPartitionLeader> subscribedPartitions;
/** The offsets of the last returned elements */
- private transient long[] lastOffsets;
+ private transient HashMap<KafkaTopicPartition, Long> lastOffsets;
/** The latest offsets that have been committed to Kafka or ZooKeeper.
These are never
* newer then the last offsets (Flink's internal view is fresher) */
- private transient long[] commitedOffsets;
+ private transient HashMap<KafkaTopicPartition, Long> commitedOffsets;
--- End diff --
Type in the variable name: "committed"
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
