sanghyeok An created KAFKA-16648:
------------------------------------
Summary: Question: KIP-848 and KafkaTestKit.java
Key: KAFKA-16648
URL: https://issues.apache.org/jira/browse/KAFKA-16648
Project: Kafka
Issue Type: Bug
Reporter: sanghyeok An
Attachments: image-2024-04-30-19-19-12-316.png,
image-2024-04-30-19-20-14-427.png
Hi, Kafka Team.
I am writing test code for the new rebalancing protocol proposed in KIP-848.
It works well in general code. However, it does not work properly when creating
an EmbeddedBroker using KafkaTestKit.java.
### Phenomena
# Create a CombineBroker that acts as both controller and broker using
KafkaTestKit.
# Consumer do subscribe() and poll() to created Broker.
At this time, the Consumer sends a HeartBeat Signal to the Broker successfully.
However, it never receives a Partition Assigned response from the Broker.
### What is my broker configs?
!image-2024-04-30-19-19-12-316.png|width=530,height=228!
### Actual Broker Config.
!image-2024-04-30-19-20-14-427.png|width=465,height=151!
I set controller.quorum.voters = 0@localhost:9093, but 0@0.0.0.0.0:0 is setted.
Because of this codes
([https://github.com/apache/kafka/blob/7c0a302c4da9d53a8fddc504a9fac8d8afecbec8/core/src/test/java/kafka/testkit/KafkaClusterTestKit.java#L305-L307)]
### My opinion.
I am not familiar with the broker's quorum, but it seems to be the problem.
I expect that when the Consumer sends a poll request to the broker, the group
coordinator broker assigns the topic/partition and then performs quorum for
each epoch number.
However, it seems to not work because the controller to vote is represented as
0.0.0.0:0.
This setting does not work well when applied to containers in docker-compose.
Could this be the cause of the problem?
### Question
If {{controller.quorum.voters}} is set to {{0.0.0.0:0}} and i want to use
consumer group rebalancing through KIP-848, what settings should be applied to
the brokers and consumers?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
