Created 03-28-2017 01:48 PM
kafka-issue.pngGetting issue in kafka topic creation command
"bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 1 --partitions 1"
PFA screen shot for reference
Created 03-28-2017 02:00 PM
Want to get a detailed solution you have to login/registered on the community
Register/LoginCreated 03-28-2017 02:00 PM
Want to get a detailed solution you have to login/registered on the community
Register/LoginCreated 03-29-2017 05:34 AM
Thanks for the quick solution... it worked for me, but did not try the Strom kafka spout configuration.
Created 03-29-2017 05:40 AM
Good to know that previously mentioned suggestion worked.
Regarding the "spoutConfig.securityProtoco
" config you can refer to the following link to know more about it. Sometimes an incorrect value to this property causes issue, but in your case looks like it is alredy running fine.
Created 03-29-2017 05:51 AM
It will be good if you can mark this HCC thread as Answerd by clicking on the "Accept" button on the correct answer that helps others.
Created 03-29-2017 01:21 PM
@Jay SenSharma : Sure i will do that.
Hhaving another issue while executing kafka consumer
Created 03-29-2017 01:46 PM
Currently i am getting "No brokers found in ZK." issue for the following command
"kafka-console-consumer.sh --zookeeper abc00691239901.cde.com:6667 --topic test --from-beginning"
Created 08-02-2017 05:25 AM
@Sanjib Behera Is this the same issue as provided in screenshot ? If yes, Could you please check "listeners" section in server.properties. As you are not using kerberos while consuming value of "listeners" should contain PLAINTEXT.
If this is a different error then please provide complete traceback message.
Created 08-02-2017 06:45 AM
if the cluster is Kerberos enabled then we need "kafka-console-consumer.sh --zookeeper abc00691239901.cde.com:6667 --topic test --from-beginning --security-protocol PLAINTEXTSASL" and for Storm spout you need to have jaas file to be configured.