[BEAM-928] Enable Spotbugs in KafkaIO

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.12.0
• Component/s: io-java-kafka
• Assignee: Alexey Romanenko
• Reporter: Dan Halperin
• Created: 07/Nov/16 17:18
• Updated: 16/May/20 13:39
• Resolved: 25/Mar/19 16:31

Description

[INFO] Inconsistent synchronization of org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader$PartitionState.latestOffset; locked 75% of time [org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader, org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader$PartitionState, org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader$PartitionState, org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader$PartitionState] Unsynchronized access at KafkaIO.java:[line 1064]Synchronized access at KafkaIO.java:[line 822]Synchronized access at KafkaIO.java:[line 827]Synchronized access at KafkaIO.java:[line 830] 

Issue Links

• links to: GitHub Pull Request #8120