Re: Getting partition null or empty error @Apache Apex-Kafka Integration

Hi Tushar I am able to telnet zookeeper service from every node in the cluster. On Tue, Jul 12, 2016 at 11:26 AM, Tushar Gosavi wrote: > Hi Anuj, > > I have observed similar problem in the past. most probably the > application master is unable to connect to kafka

Re: Getting partition null or empty error @Apache Apex-Kafka Integration

Hi Anuj, I have observed similar problem in the past. most probably the application master is unable to connect to kafka cluster. can you check if you are using correct version of kafka client, And your kafka cluster is accessible with configuration you have provided. Regards, -Tushar. On Tue,

Re: Getting partition null or empty error @Apache Apex-Kafka Integration

Anuj, Could you provide additional details such as: What does your DAG look like ? What operators (custom as well as from Malhar) are you using ? Does this exception happen immediately upon launch or after some time ? Ram On Mon, Jul 11, 2016 at 10:12 PM, ANUJ THAKWANI

Re: Getting partition null or empty error @Apache Apex-Kafka Integration

Hi, I have subscribed to the dev list. Let me know the way forward. I am a newbie in this project . On Tue, Jul 12, 2016 at 10:31 AM, Amol Kekre wrote: > > Anuj, > You are not yet subscribed to dev list, and hence will have trouble > posting to this forum. Please

Getting partition null or empty error @Apache Apex-Kafka Integration

Hi, I am getting below given exception while launching kafka Application. Please let me know how to fix this. java.lang.IllegalStateException: Partitioner returns null or empty. at com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:605) at