Re: same keys appearing in state stores on different pods when using branches in kafka streams

2022-12-05 Thread John Roesler
Hi Pushkar, I'm sorry for the delay. I'm afraid I'm having trouble picturing the situation. Can you provide the topology description? That will show us whether we should expect the stores to always be in the same instances or not. If you can also include a simplified version of your program,

Re: Supported Kafka/Zookeeper Version with ELK 8.4.3

2022-12-05 Thread sunil chaudhari
Hi All, Well this question can be asked on discuss.elastic.co However I would like to answer this. I am sure you need compatibility with logstash. You can go through this document for logstash-kafka integration https://www.elastic.co/guide/en/logstash/current/plugins-integrations-kafka.html

Re: Supported Kafka/Zookeeper Version with ELK 8.4.3

2022-12-05 Thread Colin McCabe
Hi, Sorry, we do not develop ELK. In fact, I'm not sure what that acronym refers to. I would suggest checking in with support for that product / project, since it is not part of Apache Kafka. best, Colin On Fri, Oct 28, 2022, at 06:23, Kumar, Sudip wrote: > Hi Team, > > We are still

Re: same keys appearing in state stores on different pods when using branches in kafka streams

2022-12-05 Thread Pushkar Deole
John or Matthias can you help here, we are frequently getting errors like below: org.apache.kafka.streams.errors.InvalidStateStoreException: The state store, records, may have migrated to another instance. For the same key, the record exist in totals state store but not in 'records' state

Re: Kafka service unavailable

2022-12-05 Thread John Roesler
Hi Rakesh, I'm sorry for your trouble. The mailing list doesn't transmit embedded images, so we can't see the information you provided. Maybe you can create a Github Gist or open a Jira ticket at https://issues.apache.org/jira/projects/KAFKA/issues ? Thanks, -John On Sun, Dec 4, 2022, at