Kafka topic inconsistency

Hello, We have the following code to send avro message to a topic (Please find the code snippet below). Although the ProducerResord received a complete acknowledgement withiot exception, the message is never stored in this topic. In the log we can see the following message is logged:

Re: Kafka Stream Exception: partition issue

st the information to all brokers. > > https://docs.confluent.io/current/streams/developer- > guide/config-streams.html#kafka-consumers-and-producer- > configuration-parameters > > Please let us know if this resolved the issue. > > > -Matthias > > On 11/20/17 7:22 AM, D S

Kafka Stream Exception: partition issue

Hello, We are using Kafka version 0.11.0.1. with KafkaStream. Using the leftJoin API in the Kafka Stream: KStream leftJoin(KStream otherStream, ValueJoiner joiner, JoinWindows windows)

Re: Kafka Stream invalid partitions

Thanks Eno, for the info!. I will try your suggestion. 2017-06-27 14:04 GMT+02:00 Eno Thereska <eno.there...@gmail.com>: > Thanks. I believe we’ve addressed this issue in 0.10.2.1, any chance you > could try that? > > Thanks > Eno > > On Jun 27, 2017, at 11:

Re: Kafka Stream invalid partitions

e report. What version of Kafka are you using? Also, between > runs do you change the number of partitions for your topics? I’m trying to > figure out how this problem happens, any information on what is changing in > between runs is appreciated. > > Thanks, > Eno > > > On

Kafka Stream invalid partitions

Hello, When I use KafkaStreams DSL GroupByKey and Aggregate APIs, I have randomly & frequently below exceptions: In my opinion, it is not practical to clean up the invalid partitions everydays. For your information, this partition is an internal partition that automatically created by