I believe this issue was already resolved. In this particular case, the ISR were not updated appropriately and the offsets on couple of brokers were not in sync with rest of them. Once this issue was fixed, the error was no longer visible. The offsets not being in sync is attributed to network incident where we had continuous flaps for a long duration of time .
... View more
Hi All, I am trying to restart one of my kafka broker for stale configuration due to ranger configuration changes. However, one of the kafka broker is not coming up and is not throwing any error as well. I reverted back the ranger configuration but to no avail. The only error that i see is the below error in the ambari stderr output: Traceback (most recent call last):
File "/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py", line 129, in <module>
File "/usr/lib/python2.6/site-packages/resource_management/libraries/script/script.py", line 280, in execute
File "/usr/lib/python2.6/site-packages/resource_management/libraries/script/script.py", line 685, in restart
File "/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py", line 96, in stop
File "/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/params.py", line 181, in <module>
enable_ranger_kafka = not is_empty(enable_ranger_kafka) and enable_ranger_kafka.lower() == 'yes'
AttributeError: 'bool' object has no attribute 'lower'
... View more