I don't think beginningOffsets is null. I think it's missing one of the
partitions, which would mean the right hand side of the line is null, which
gives an NPE when we try to assign it to a primitive long.
I think this could be due to
https://issues.apache.org/jira/browse/KAFKA-7044, going by
Hello,
Using Storm 1.2.3-snapshot of the 3rd of November 2018 with all libs
(storm-core & storm-kafka-client) taken from same Git, we get the
following crash coming from a NullPointerException in
KafkaOffsetMetric.getValueAndReset :
2018-11-12 19:31:30.496 o.a.s.util
Github user arunmahadevan commented on the issue:
https://github.com/apache/storm/pull/2906
@VipinRathor
I pulled in the relevant changes from
https://github.com/apache/storm/pull/2760 and created this so that we can take
it forward. I need to do some tests and will update once
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/storm/pull/2906
STORM-3123 - add support for Kafka security config in storm-kafka-monitor
You can merge this pull request into a Git repository by running:
$ git pull
Hi Ashwin,
Here are some steps I follow. Please skip steps that you already know.
Initial:
1. git clone g...@github.com:apache/storm.git
General steps:
1. Make modification to the source code.
2. Let’s say the source code is located at ~/Workspace/storm. Recompile and
rebuild a storm binary
