Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

How to setup kafka cluster on hortonworks platform

avatar

Can some one point me in right direction of how to setup KAFKA cluster on HDP platform.

To setup kafka clusters usually we add broker.id=1,2,3... but hortonworks doesn't provide this option to add in thr..

Issue: is when i try to create kafka topics i am able to create with 2,3 partitions and replicas 2,3.. but starting consumer and producer start throwing exception unknown topic or partition. My guess is it;s due to kafka HA configuration..

1 ACCEPTED SOLUTION

avatar

Hey @Pankaj Singh!
Not sure if I get it right, but, how are you consuming/producing to/from kafka topics?
Through kafka-console-consumer/kafka-console-producer?

Could you share with us the output from the following commands?

[root@node2 ~]# kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --describe --topic vini
Topic:vini  PartitionCount:3  ReplicationFactor:3 Configs:message.timestamp.type=LogAppendTime
  Topic: vini Partition: 0  Leader: 1001  Replicas: 1001,1002,1003  Isr: 1002,1003,1001
  Topic: vini Partition: 1  Leader: 1002  Replicas: 1002,1003,1001  Isr: 1002,1003,1001
  Topic: vini Partition: 2  Leader: 1003  Replicas: 1003,1001,1002  Isr: 1002,1003,1001
[root@node2 ~]# kafka-console-producer.sh --broker-list node2:6667 --topic vini 
>testing testing
>this is a test        
>hcc 
[root@node2 ~]# kafka-console-consumer.sh --bootstrap-server node2:6667 --topic vini --from-beginning this is a test testing testing hcc [root@node2 ~]# zookeeper-client [zk: localhost:2181(CONNECTED) 9] ls /brokers/topics/vini/partitions [0, 1, 2]

Hope this helps!

View solution in original post

2 REPLIES 2

avatar

Hey @Pankaj Singh!
Not sure if I get it right, but, how are you consuming/producing to/from kafka topics?
Through kafka-console-consumer/kafka-console-producer?

Could you share with us the output from the following commands?

[root@node2 ~]# kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --describe --topic vini
Topic:vini  PartitionCount:3  ReplicationFactor:3 Configs:message.timestamp.type=LogAppendTime
  Topic: vini Partition: 0  Leader: 1001  Replicas: 1001,1002,1003  Isr: 1002,1003,1001
  Topic: vini Partition: 1  Leader: 1002  Replicas: 1002,1003,1001  Isr: 1002,1003,1001
  Topic: vini Partition: 2  Leader: 1003  Replicas: 1003,1001,1002  Isr: 1002,1003,1001
[root@node2 ~]# kafka-console-producer.sh --broker-list node2:6667 --topic vini 
>testing testing
>this is a test        
>hcc 
[root@node2 ~]# kafka-console-consumer.sh --bootstrap-server node2:6667 --topic vini --from-beginning this is a test testing testing hcc [root@node2 ~]# zookeeper-client [zk: localhost:2181(CONNECTED) 9] ls /brokers/topics/vini/partitions [0, 1, 2]

Hope this helps!

avatar

I apology for not putting the answer earlier. I was able to resolve the issue. Issue was due to ranger policy setup on Kafka topics.

After turning off the ranger policy it works out of the box. Kafka cluster creates a meta.properties folder. HDP infra setups the Kafka in cluster from start