Edoardo Comar created KAFKA-19443:
-------------------------------------
Summary: test-common ClusterInstance should make it easy to have
more listeners
Key: KAFKA-19443
URL: https://issues.apache.org/jira/browse/KAFKA-19443
Project: Kafka
Issue Type: Improvement
Components: unit tests
Reporter: Edoardo Comar
Assignee: Edoardo Comar
I wanted to write a @ClusterTest where the protocol security map specified
different protocols for the client and for interbroker traffic.
e.g.
{code}
"INTER_BROKER:PLAINTEXT,CLIENT:SASL_PLAINTEXT,CONTROLLER:PLAINTEXT"
{code}
The current KafkaClusterTestKit does not provide an easy way for the clients to
use a listener that is not the default EXTERNAL listener
the individual brokers bound ports are accessible with a call like
{code}
cluster.brokers().get(0).boundPort(ListenerName.normalised("CLIENT"))
{code}
but it's simpler is the ClusterInstance offers an overloaded method like
{code}
String booostrapServers(LstenerName)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)