Stig Rohde Døssing created STORM-3535:
-----------------------------------------
Summary: KafkaOffsetMetric is not properly synchronized
Key: STORM-3535
URL: https://issues.apache.org/jira/browse/STORM-3535
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka-client
Affects Versions: 2.1.0
Reporter: Stig Rohde Døssing
KafkaOffsetMetric.getValueAndReset runs in a different thread from the rest of
the spout. It uses the KafkaConsumer from the KafkaSpout. The consumer is
accessed through an unsynchronized field, and the spout may replace the
consumer at any time.
We should consider whether we can fix this, or if it would be better to give
the offset metric it's own consumer.
Also the metric accesses a number of properties in OffsetManagers, which are
also not synchronized.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
