如何在 server.properties 文件中配置 Apache Kafka 代理端口答案

【问题标题】：How to configure Apache Kafka broker port in server.properties file如何在 server.properties 文件中配置 Apache Kafka 代理端口
【发布时间】：2021-04-08 04:54:32
【问题描述】：

在创建生产者时，我必须指定代理端口值。

为此，我需要在“server.properties”文件中配置代理端口值。

这些“listeners”和“advertised.listeners”参数是什么，以及如何将它们配置为代理端口？

如果代理端口值是强制性的，那么为什么要对这些参数进行注释？

如果这些参数是从 'java.net.InetAddress.getCanonicalHostName()' 自动初始化的，那么如何在创建新生产者时指定这些自动初始化的端口值？

谢谢。

############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

# Hostname and port the broker will advertise to producers and consumers. If not set, 
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
#advertised.listeners=PLAINTEXT://your.host.name:9092

【问题讨论】：

标签： apache-kafka

【解决方案1】：

为什么这些参数有注释？

正如 cmets 所说，他们有默认值

如果这些参数是从 'java.net.InetAddress.getCanonicalHostName()' 自动初始化的，那么如何在创建新生产者时指定这些自动初始化的端口值？

默认端口是 9092，因此您将在端口 9092 上连接到该 IP/主机名。

这些 'listeners' 和 'advertised.listeners' 参数是什么

https://www.confluent.io/blog/kafka-listeners-explained/

【讨论】：

【解决方案2】：

如果不设置advertised.listeners，则默认与listeners相同。

listeners用于内网IP，advertised.listeners用于外网IP。如果只需要在里面使用Kafka，只需要配置listeners即可。

listeners是socketserver实际bind()的参数。 advertised.listeners 将存储在 zk 中。

在内部网络中，您可以使用 192.168.0.10 连接 Kafka Broker。通过外部网络，您应该配置advertised.listeners

# inside network IP, like that
listeners=PLAINTEXT://192.168.0.10:9092

# Public network ip, so you can connect the broker in any network
advertised.listeners=PLAINTEXT://xxx.xxx.xxx.xxx:9092

其他：参数值的格式为(协议名)://(主机名或ip):(端口号)

协议名PLAINTEXT表示明文传输，

协议名SSL表示使用SSL或TLS加密传输等

【讨论】：