Hi @Gitanjali Bare, Could you please share the complete error you are getting? Thanks! ... View more

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

@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

@dhieru singh No problem at all, I am glad it helped! ... View more

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

@sohan kanamarlapudi Hi, May I know what version of Spark and Kafka are you using? Thanks! ... View more

@Mahesh Glad it worked! Thanks! ... View more

@Mahesh Hi, Did the suggestion help? Thanks! ... View more