Member since
06-14-2016
69
Posts
28
Kudos Received
7
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
7029 | 07-30-2018 06:45 PM | |
5557 | 06-22-2018 10:28 PM | |
1435 | 06-20-2018 04:29 AM | |
1420 | 06-20-2018 04:24 AM | |
2906 | 06-15-2018 08:24 PM |
09-25-2018
10:49 PM
Hi @Gitanjali Bare, Could you please share the complete error you are getting? Thanks!
... View more
08-17-2018
06:28 AM
Hi @Surendra Shringi, May I know if you are connecting to a Kerberized Kafka or unsecure? For template , kindly refer: https://community.hortonworks.com/articles/57262/integrating-apache-nifi-and-apache-kafka.html Its an old article but it covers the basics in detail. Also, is Kafka in the same HDF cluster or are you using a separate Kafka cluster? Thanks!
... View more
08-16-2018
06:26 PM
@Surendra Shringi Hi, Could you please try passing the FQDN of the kafka broker in the 'Kafka Brokers property of the processor? Also may I know what version of Kafka are you trying to publish to? Thanks!
... View more
07-30-2018
06:54 PM
@dhieru singh No problem at all, I am glad it helped!
... View more
07-30-2018
06:45 PM
@dhieru singh
Hi,
Below are the options that you can use with ./kafka-consumer-groups.sh --reset-offsets: For a specific topic you can use --topic option instead of --all-topics. Please let me know if that answers your question. Thank you!
... View more
07-11-2018
06:52 PM
Thank you @sohan kanamarlapudi. Did you set partition.assignment.strategy to null or empty string in your properties file which is being read by your spark application? Possible values for this property is range or roundrobin and default is [org.apache.kafka.clients.consumer.RangeAssignor] Reference: https://kafka.apache.org/0100/documentation.html#newconsumerconfigs Is it possible for you to share the code snippet where you have configured the Kafka consumer? (Kindly omit any sensitive information) Thanks!
... View more
07-10-2018
08:37 PM
@sohan kanamarlapudi Hi, May I know what version of Spark and Kafka are you using? Thanks!
... View more
06-26-2018
06:25 PM
@Mahesh Glad it worked! Thanks!
... View more
06-25-2018
10:51 PM
@Mahesh Hi, Did the suggestion help? Thanks!
... View more
06-22-2018
10:28 PM
2 Kudos
@Mahesh Hi, Could you please give Kafka broker hostname:port instead of zookeeper_host:2181 in the command? The following error: WARN NetworkClient: Bootstrap broker ip-10-28-3-35.ec2.internal:2181 disconnected
Means that its unable to reach to correct Kafka broker because zookeeper information has been given. Please let me know how it goes. Thanks!
... View more