Re: Can a controller in a kafka kraft cluster be a bootstrap server

Hello, I have 3 node kafka cluster, when one node goes down for some reason the request which are serving on down node is not routing to other running node, It takes me always to restart the services, Running on kafka version 3.2.1 (kraft mode) On Mon, Dec 11, 2023 at 12:33 PM Luke Chen wrote: >

Re: Kafka frequent disconnection issue

Hello, I have 3 node kafka cluster, when one node goes down for some reason the request which are serving on down node is not routing to other running node, It takes me always to restart the services, Running on kafka version 3.2.1 (kraft mode) On Mon, Dec 11, 2023 at 12:40 PM Luke Chen wrote: >

Re: Can a controller in a kafka kraft cluster be a bootstrap server

ND_PROCESS-TEST_123-1 at offset 329: This is not the correct coordinator. On Wed, Dec 13, 2023 at 11:40 AM Luke Chen wrote: > Hi Vikram, > > It would be good if you could share client and broker logs for > troubleshooting. > > Thanks. > Luke > > On Wed, Dec 13,

Re: In Kafka KRaft can controllers participate as bootstrap servers

Hello, Why am I getting below logs continuously, how can I configure to avoid this. 11:32:43.469 WARN org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=javaproducer11703811766106] Received invalid metadata error in produce request on partition CCR_CLZ_COM_STATUS_MONITOR-PREDE

Re: Can a controller in a kafka kraft cluster be a bootstrap server

.. Going to request metadata update now On Wed, Dec 13, 2023 at 11:51 AM Vikram Singh < vikram.si...@clouzersolutions.com> wrote: > Hello Luke, > Please look into below logs, > > 12:32:15.813 WARN org.apache.kafka.clients.NetworkClient - [AdminClient > clientId=tes

Re: Question about using public classes from the internal packages

Hello Team, I have done setup of 3 node kafka cluster(3.4.1) all nodes within cluster are configured as broker and controller due to some reasons i have restarted kafka cluster. but after restarting kafka cluster nodes are not getting in the same cluster. Can you please help me out with this issue?

Re: Question about using public classes from the internal packages

? On Wed, Dec 20, 2023 at 6:00 PM Vikram Singh < vikram.si...@clouzersolutions.com> wrote: > Hello Team, > I have done setup of 3 node kafka cluster(3.4.1) all nodes within cluster > are configured as broker and controller due to some reasons i have > restarted kafka

Re: Kafka Streams: understanding re-key operations for joins

+Ajit Kharpude On Fri, Feb 23, 2024 at 1:14 PM Karsten Stöckmann < karsten.stoeckm...@gmail.com> wrote: > Hi, > > I am observing somewhat unexpected (from my point of view) behaviour > while ke-key / re-partitioning operations in order to prepare a > KTable-KTable join. > > Assume two (simplifie

Re: request to be contributor

Hi, Can we run multiple kafka streams with the same stream-id. On Wed, Jul 24, 2024 at 12:15 PM Josep Prat wrote: > Hi Yang, > > I added you to Jira. I couldn't find your username for the Wiki page > (Confluence) so I didn't set that up. But you are now all set in regards to > Jira. Let me know

Facing issue while producing

Hello, I am facing issues while producing messages on kafka topics. I am facing this issue randomly. Please help me by referring to the logs below. Logs :- 1). ERROR [ReplicaManager broker=0] Error processing append operation on partition MHM_CLZ_COM-AWS_123-7 (kafka.server.ReplicaManager) org.a

Re: Facing issue while producing

2024 at 5:56 PM Akash Jain wrote: > Hi Vikram. Can you share you code snippet? Are you using compression on > producer/broker side? > > On Friday, August 23, 2024, Vikram Singh .invalid> > wrote: > > > Hello, > > > > I am facing issues while producing mes

Re: Facing issue while producing

Hello Akash, It's the same on the broker side as well. *Broker side config:-* compression.type=snappy On Mon, Aug 26, 2024 at 9:30 PM Akash Jain wrote: > And what is it on broker? > > On Sunday, August 25, 2024, Vikram Singh .invalid> > wrote: > > > Hello Akash

Re: Facing issue while producing

ic producer shows this problem? Or does a specific broker show > this > >problem? Have you observed any pattern at all? > > > > Do you see these exceptions in broker? I guess yes. Broker will > decompress > > the messages. It is likely because the version of snappy

Re: Facing issue while producing

leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition `Error : org.apache.kafka.common.errors.OutOfOrderSequenceException: The broker received an out of order sequence number On Fri, Aug 30, 2024 at 9:04 AM Vikram Singh wrote

Re: Facing issue while producing

fka cluster. So focus on > brokers' health and stability. Investigate if there are issues with your > brokers. > > On Thu, Sep 12, 2024 at 10:23 AM Vikram Singh > wrote: > > > Hello Akash, > > > > I am getting below error logs sometimes when a kafka produce