AttributeError: 'int' object has no attribute 'leader'

[aliayen]

I am trying to use corruption check with valid parameters:

kafka-corruption-check --cluster-type sample_type --cluster-name $MY_CLUSTER_NAME --data-path $KAFKA_LOGS_PATH --minutes 30

But get this error:

Filtering leaders
Traceback (most recent call last):
File "/opt/rh/python27/root/usr/bin/kafka-corruption-check", line 6, in
run()
File "/opt/rh/python27/root/usr/lib/python2.7/site-packages/kafka_utils/kafka_corruption_check/main.py", line 535, in run
args.end_time,
File "/opt/rh/python27/root/usr/lib/python2.7/site-packages/kafka_utils/kafka_corruption_check/main.py", line 447, in check_cluster
broker_files = filter_leader_files(cluster_config, broker_files)
File "/opt/rh/python27/root/usr/lib/python2.7/site-packages/kafka_utils/kafka_corruption_check/main.py", line 395, in filter_leader_files
leader_of = get_partition_leaders(cluster_config)
File "/opt/rh/python27/root/usr/lib/python2.7/site-packages/kafka_utils/kafka_corruption_check/main.py", line 364, in get_partition_leaders
result[topic_partition] = p_data.leader

[Baisang]

@aliayen could you provide more information about what version of Kafka you are running?