Re: Error while fetching metadata only for one specific topic

Hi , On producer and consumer both side i am getting this error . WARN Error while fetching metadata with correlation id 96 : {Data=LEADER_NOT_AVAILABLE} But when i describe topic it says : Topic: DataPartition: 0Leader: 1Replicas: 1Isr: 1 What could be issue ? *Regards,* *

Error while fetching metadata only for one specific topic

Hi , I am getting below error . WARN Error while fetching metadata with correlation id 1 : {DeviceData=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient) *Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:-9741292048,8345847473*

Re: Kafka Connect requestTaskReconfiguration

OK, thanks Ewen. On Sun, Jan 15, 2017 at 4:42 PM, Ewen Cheslack-Postava wrote: > This is currently expected. Internally the Connect cluster uses the same > rebalancing process as consumer groups which means it has similar > limitations -- all tasks must stop just as you would need to stop consu

Re: Kafka Connect requestTaskReconfiguration

This is currently expected. Internally the Connect cluster uses the same rebalancing process as consumer groups which means it has similar limitations -- all tasks must stop just as you would need to stop consuming from all partitions and commit offsets during a consumer group rebalance. There's a

Re: Kafka Streams: from a KStream, aggregating records with the same key and updated metrics ?

Hi Eno, 2. Well, records could arrive out of order. But it should happen rarely, and it's no big deal anyway. So let's forget about the version number if it makes things easier ! 3. I completely missed out on KTable aggregations. Thanks a lot for the pointer, that opens new perspectives. ... a f

Kafka Streams: setting the compression codec for intermediate and output topics

Hi, how would I enable compression for records produced by Kafka Streams. By adding the producer property "compression.type" to the props sent to the `KafkaStreams` constructor ? Or it would reuse the compression codec used in input topics ? Thanks. Nicolas

Re: Debugging Kafka Connect connector in a IDE

Hi Konstantine, it's working fine thanks ! Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Advisor Twitter : @ppatierno Linkedin : paolopatierno Blog : DevExpe