thanhnd1996 created KAFKA-17859:
-----------------------------------
Summary: Bug
Key: KAFKA-17859
URL: https://issues.apache.org/jira/browse/KAFKA-17859
Project: Kafka
Issue Type: Bug
Components: controller
Affects Versions: 3.2.0
Environment: dedicate server, kafka cluster 3 node , running on systemd
Reporter: thanhnd1996
Attachments: Alert-ERROR-Elasticsearch.png,
Image-failed-Controller.png, failed-producer-init-from-service.png
Subject: Bug when Kafka Producer Initializes Message Publishing
Hi Admin,
I'm encountering an issue with my Kafka cluster (3 nodes, running in KRaft
mode). After performing maintenance on one of the nodes and restarting the
Kafka service (using systemd), I’m facing an error when trying to connect and
initialize a transaction to a topic (e.g., {{{}topic_A{}}}, 1 partition, 2
replicas).
After reconnecting, Kafka throws the following exception:#
kafka-server-start.sh[77303]: [2024-10-22 12:19:25,145] ERROR [Controller 1]
allocateProducerIds: unable to start processing because of
NotControllerException. (org.apache.kafka.controller.QuorumController)
I’ve restarted the Kafka service, but the exception repeats each time the
service initializes a transaction. Below is my configuration (in C#):
{
"Id": "Securities",
"Topic": "Topic_A",
"BootstrapServers": "10.26.7.58,10.26.7.59,10.26.7.60,10.26.7.68,10.26.7.69",
"Acks": -1,
"TransactionTimeoutMs": 300000,
"MessageTimeoutMs": 120000,
"QueueBufferingMaxMessages": 1048576,
"EnableIdempotence": true,
"MaxInFlight": 5,
"LingerMs": 0
}.
I hope admin can help me figure out the issue.
Thank you!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)