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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.2
• Fix Version/s: 2.6.0
• 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: 23/Oct/23 18:15
• Resolved: 23/Oct/23 18:15

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/3377

 

Issue Links

• links to: GitHub Pull Request #3016