从 Java 连接到 Apache Kafka 的问题答案

【问题标题】：problem connecting to Apache Kafka from Java从 Java 连接到 Apache Kafka 的问题
【发布时间】：2021-01-23 18:50:58
【问题描述】：

我正在尝试连接到一台 Kafka 服务器。在 Java 中，我已配置：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.NewTopic;
.
.
Properties properties = new Properties();
String bootstrapServers = "localhost:9092";
properties.put("bootstrap.servers", bootstrapServers);
properties.put("connections.max.idle.ms", 10000);
properties.put("request.timeout.ms", 5000);
try {
        AdminClient adminClient = AdminClient.create(properties);
        NewTopic newTopic = new NewTopic("testtopic", 1, (short)1); 
.
.

虽然有使用 localhost 的配置，但出现错误：

INFO: AdminClientConfig values: 
    bootstrap.servers = [localhost:9092]
Jan 22, 2021 9:48:01 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo <init>
INFO: Kafka version: 2.7.0
Jan 22, 2021 9:48:01 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo <init>
INFO: Kafka commitId: 448719dc99a19793
Jan 22, 2021 9:48:01 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo <init>
INFO: Kafka startTimeMs: 1611348481265
Jan 22, 2021 9:48:03 PM org.apache.kafka.clients.NetworkClient initiateConnect
WARNING: [AdminClient clientId=adminclient-1] Error connecting to node e4f0851caf23:9092 (id: 1001 rack: null)
java.net.UnknownHostException: No such host is known (e4f0851caf23)

我是否缺少任何其他配置？这只是一个示例代码，我正在尝试创建一个主题。

谢谢！

【问题讨论】：

你在docker中运行Kafka服务器吗？那么你可能需要配置Kafka服务器本身的advertised.listeners属性。本指南应提供详细信息：confluent.io/blog/…

标签： java apache-kafka

【解决方案1】：

谢谢雅皮士流感！我必须补充：

KAFKA_CFG_ADVERTISED_LISTENERS=INTERNAL://kafka:9093,CLIENT://kafka:9092

【讨论】：