Re: Consumer not reporting to kafka consumer group

2019-03-04 Thread Parth Gandhi
Dear users, Any suggestion on this? We are now facing this issue for prod as well. We have a .net consumer running on windows servers along with the other consumers. only one of the consumer is giving this error. I also see the consumer_group is not getting created for this topic. Thanks, Parth G

Produce Message Conversions Per Sec

2019-03-04 Thread Peter Bukowinski
Greetings, I have a concern about the produce message conversions per sec metrics of my kafka brokers. I have a go application that produces topics into a kafka 2.0.1 cluster using confluent-kafka-go with librdkafka 0.11.6 (and log.message.format.version=2.0). The produce conversions/sec metric

Re: KTable.suppress(Suppressed.untilWindowCloses) does not suppress some non-final results when the kafka streams process is restarted

2019-03-04 Thread John Roesler
Hi Jonathan, Sorry to hear that the feature is causing you trouble as well, and that the 2.2 release candidate didn't seem to fix it. I'll try and do a repro based on the code in your SO post tomorrow. I don't think it's related to the duplicates, but that shutdown error is puzzling. Can you pri