Re: Kafka streams state store return hostname as unavailable when calling queryMetadataForKey method

2024-05-09 Thread Penumarthi Durga Prasad Chowdary
Kafka upgraded from 3.5.1 to 3.7.0 version On Fri, May 10, 2024 at 2:13 AM Sophie Blee-Goldman wrote: > What version did you upgrade from? > > On Wed, May 8, 2024 at 10:32 PM Penumarthi Durga Prasad Chowdary < > prasad.penumar...@gmail.com> wrote: > > > Hi Team

Kafka streams state store return hostname as unavailable when calling queryMetadataForKey method

2024-05-08 Thread Penumarthi Durga Prasad Chowdary
Hi Team, I'm utilizing Kafka Streams to handle data from Kafka topics, running multiple instances with the same application ID. This enables distributed processing of Kafka data across these instances. Furthermore, I've implemented state stores with time windows and session windows. To retrieve

Re: Failed to initialize processor KSTREAM-AGGREGATE-0000000001

2024-05-03 Thread Penumarthi Durga Prasad Chowdary
using? > > It would be best if you could file a Jira ticket and we can take it from > there. > > > -Matthias > > On 4/21/24 5:38 PM, Penumarthi Durga Prasad Chowdary wrote: > > Hi , > > I have an issue in kafka-streams while constructing kafka-streams state > &

Failed to initialize processor KSTREAM-AGGREGATE-0000000001

2024-04-21 Thread Penumarthi Durga Prasad Chowdary
Hi , I have an issue in kafka-streams while constructing kafka-streams state store windows(TimeWindow and SessionWindow). While kafka-streams processing data sometimes intermittent kafka-streams process throwing below error ThreadName:

Reg : Kafka cluster issue

2021-07-07 Thread Penumarthi Durga Prasad Chowdary
Hi , I have an environment like kafka cluster with 3 brokers & kafka-streams to process data of kafka topic. Here kafka & kafka-streams versions are 2.7.0 . Which is working fine for sometime , later having issues in kafka-streams, in logs showing below error's - Execution error

Reg : kafka state store HA

2019-11-17 Thread Penumarthi Durga Prasad Chowdary
Hi , Working on kafka-streams to process data & stored into state-store(stored into local file system & changelog topic as well).Two streams instances are started for HA & performance improvement ,then streams are re-balanced the topic partition to process. Here we are facing issue with