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

2023-12-17 Thread Vikram Singh
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

2023-12-12 Thread Vikram Singh
Hello Luke, Please look into below logs, 12:32:15.813 WARN org.apache.kafka.clients.NetworkClient - [AdminClient clientId=test-lgn-clz-com-v0.0.43-INS_CLZ_COM-TEST_123-7e87eb30-69e9-4746-b351-beac3a085383-admin] Error connecting to node kafka-0-0.kafka.test.svc.cluster.local:9092 (id: 0 rack: nul

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

2023-12-12 Thread Luke Chen
Hi Vikram, It would be good if you could share client and broker logs for troubleshooting. Thanks. Luke On Wed, Dec 13, 2023 at 1:15 PM Vikram Singh wrote: > > 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 routi

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

2023-12-12 Thread Vikram Singh
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: Can a controller in a kafka kraft cluster be a bootstrap server

2023-12-10 Thread Luke Chen
Hi Dima, You can set "process.roles=controller,broker" to get what you want. Otherwise, the controller role cannot be served as a broker. Thanks. Luke On Sat, Dec 9, 2023 at 3:59 AM Dima Brodsky wrote: > Hello, > > Would the following configuration be valid in a kafka kraft cluster > > So lets

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

2023-12-08 Thread Dima Brodsky
Hello, Would the following configuration be valid in a kafka kraft cluster So lets say we had the following configs for a controller and a broker: === controller - https://github.com/apache/kafka/blob/6d1d68617ecd023b787f54aafc24a4232663428d/config/kraft/controller.properties process.roles=cont