I was able to dig up more information about this problem, filed this:
https://jira.apache.org/jira/browse/STORM-3337
Hello,
I was hoping for guidance on an issue I've been seeing. I have a topology
that uses `org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaque` to
read from a Kafka topic with a reset strategy of UNCOMMITTED_EARLIEST.
Since upgrading from 1.0.5 to 1.2.3 the offsets that the topology
afka/spout/metrics/KafkaOffsetMetric.java,
> so if you'd like to add metrics to the Trident spout it would be a good
> starting point to look at that class.
>
> Den fre. 23. nov. 2018 kl. 20.55 skrev Jonathan Munz :
>
>> Hi,
>>
>> I was looking to upgrade from 1.0.5 to 1.2
Hi,
I was looking to upgrade from 1.0.5 to 1.2.2. One thing I noticed is that
the 'kafkaOffset' metric is no longer being reported by the Kafka Trident
spout. In 1.0.5 it was being registered here:
