You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Sergey (Jira)" <ji...@apache.org> on 2024/06/18 20:48:00 UTC
[jira] [Updated] (KAFKA-16995) The listeners broker parameter incorrect documentation
[ https://issues.apache.org/jira/browse/KAFKA-16995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergey updated KAFKA-16995:
---------------------------
Description:
We are using Kafka 3.6.1 and the [KIP-797|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330] describes configuring listeners with the same port and name for supporting IPv4/IPv6 dual-stack.
Documentation link: [https://kafka.apache.org/36/documentation.html#brokerconfigs_listeners]
As I understand it, Kafka should allow us to set the listener name and listener port to the same value if we configure dual-stack.
But in reality, the broker returns an error if we set the listener name to the same value.
Error example:
{code:java}
java.lang.IllegalArgumentException: requirement failed: Each listener must have a different name, listeners: CONTROLPLANE://0.0.0.0:9090,SSL://0.0.0.0:9093,SSL://[::]:9093
at scala.Predef$.require(Predef.scala:337)
at kafka.utils.CoreUtils$.validate$1(CoreUtils.scala:214)
at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:268)
at kafka.server.KafkaConfig.listeners(KafkaConfig.scala:2120)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1807)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1604)
at kafka.Kafka$.buildServer(Kafka.scala:72)
at kafka.Kafka$.main(Kafka.scala:91)
at kafka.Kafka.main(Kafka.scala) {code}
I've tried to set the listeners to: "SSL://0.0.0.0:9093,SSL://[::]:9093"
was:
We are using Kafka 3.6.1 and the [KIP-797|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330] describes configuring listeners with the same port and name for supporting IPv4/IPv6 dual-stack.
Documentation link: https://kafka.apache.org/36/documentation.html#brokerconfigs_listeners
|{{}}|
As I understand it, Kafka should allow us to set the listener name and listener port to the same value if we configure dual-stack.
But in reality, the broker returns an error if we set the listener name to the same value.
Error example:
{code:java}
java.lang.IllegalArgumentException: requirement failed: Each listener must have a different name, listeners: CONTROLPLANE://0.0.0.0:9090,SSL://0.0.0.0:9093,SSL://[::]:9093
at scala.Predef$.require(Predef.scala:337)
at kafka.utils.CoreUtils$.validate$1(CoreUtils.scala:214)
at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:268)
at kafka.server.KafkaConfig.listeners(KafkaConfig.scala:2120)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1807)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1604)
at kafka.Kafka$.buildServer(Kafka.scala:72)
at kafka.Kafka$.main(Kafka.scala:91)
at kafka.Kafka.main(Kafka.scala) {code}
I've tried to set the listeners to: "SSL://0.0.0.0:9093,SSL://[::]:9093"
> The listeners broker parameter incorrect documentation
> -------------------------------------------------------
>
> Key: KAFKA-16995
> URL: https://issues.apache.org/jira/browse/KAFKA-16995
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 3.6.1
> Environment: Kafka 3.6.1
> Reporter: Sergey
> Priority: Minor
>
> We are using Kafka 3.6.1 and the [KIP-797|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=195726330] describes configuring listeners with the same port and name for supporting IPv4/IPv6 dual-stack.
> Documentation link: [https://kafka.apache.org/36/documentation.html#brokerconfigs_listeners]
> As I understand it, Kafka should allow us to set the listener name and listener port to the same value if we configure dual-stack.
> But in reality, the broker returns an error if we set the listener name to the same value.
> Error example:
> {code:java}
> java.lang.IllegalArgumentException: requirement failed: Each listener must have a different name, listeners: CONTROLPLANE://0.0.0.0:9090,SSL://0.0.0.0:9093,SSL://[::]:9093
> at scala.Predef$.require(Predef.scala:337)
> at kafka.utils.CoreUtils$.validate$1(CoreUtils.scala:214)
> at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:268)
> at kafka.server.KafkaConfig.listeners(KafkaConfig.scala:2120)
> at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1807)
> at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1604)
> at kafka.Kafka$.buildServer(Kafka.scala:72)
> at kafka.Kafka$.main(Kafka.scala:91)
> at kafka.Kafka.main(Kafka.scala) {code}
> I've tried to set the listeners to: "SSL://0.0.0.0:9093,SSL://[::]:9093"
--
This message was sent by Atlassian Jira
(v8.20.10#820010)