[STORM-3404] storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.2.2
• Fix Version/s: 1.2.2
• Component/s: storm-kafka-monitor
• Labels: pull-request-available
• Environment: centos 6.6 ; kafka 2.2.2 ; storm 1.2.2 ; zookeeper 3.4.8
• Assignee: Unassigned
• Reporter: XingYiWang
• Created: 04/Jun/19 06:49
• Updated: 21/Jul/19 11:54

Description

when use SASL_PLAIN kafka JAAS auth, missing sasl.mechanism will lead to KafkaOffsetLagUtil cant pull the offset correctly
kafka version 2.2.0

storm version 1.2.2

The PR url is :https://github.com/apache/storm/pull/3016

 

Issue Links

• links to: GitHub Pull Request #3016