Re: Problem with Kafka 0.9 Client

Great. That's good news. Let us know if you encounter more issues with the Kafka connector. By the way, Kafka released 0.9.0.1, maybe updating your brokers to that version resolves the issues? (Maybe the problems of some of the topics were caused by bugs in Kafka) On Tue, Feb 23, 2016 at 10:23

Re: Problem with Kafka 0.9 Client

Hi Robert, After we restarted our Kafka / Zookeeper cluster the consumer worked. Some of our topics had some problems. The flink's consumer for Kafka 0.9 works as expected. Thanks! On 19 February 2016 at 12:03, Lopez, Javier wrote: > Hi, these are the properties: > >

Re: Problem with Kafka 0.9 Client

Hi, these are the properties: Properties properties = new Properties(); properties.setProperty("bootstrap.servers", ".87:9092,.41:9092,.35:9092"); //full IPs removed for security reasons properties.setProperty("zookeeper.connect", ".37:2181");

Re: Problem with Kafka 0.9 Client

Thank you. Can you send me also the list of properties you are passing to the kafka consumer? Are you only setting the "bootstrap.servers" or more? On Fri, Feb 19, 2016 at 11:46 AM, Lopez, Javier wrote: > Hi Robert, > > Please find attached the full logs of one of our

Re: Problem with Kafka 0.9 Client

Had the same problem as Javier's. 3450 [Thread-10] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Group metadata response ClientResponse(receivedTimeMs=1455811593680, disconnected=false, request=ClientRequest(expectResponse=true,

Re: Problem with Kafka 0.9 Client

Hi Javier, sorry for the late response. In the Error Mapping of Kafka, it says that code 15 means: ConsumerCoordinatorNotAvailableCode. https://github.com/apache/kafka/blob/0.9.0/core/src/main/scala/kafka/common/ErrorMapping.scala How many brokers did you put into the list of bootstrap servers?

Problem with Kafka 0.9 Client

Hi guys, We are using Flink 1.0-SNAPSHOT with Kafka 0.9 Consumer and we have not been able to retrieve data from our Kafka Cluster. The DEBUG data reports the following: 10:53:24,365 DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request ClientRequest(expectResponse=true,