We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3ffeb79 commit ab5b88dCopy full SHA for ab5b88d
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java
@@ -481,8 +481,6 @@ public TopicPartition topicPartition() {
481
// Update consumedOffset and avgRecordSize
482
void recordConsumed(long offset, int size) {
483
nextOffset = offset + 1;
484
-
485
- // This is always updated from single thread. Probably not worth making atomic.
486
avgRecordSize.update(size);
487
}
488
0 commit comments