Azure Event Hubs for Kafka Java生产者启动失败，报EOF握手错误

从你提供的错误日志和配置来看，问题集中在SSL握手阶段的EOF异常以及连接超时，下面是几个针对性的排查和解决步骤：

1. 修正SASL JAAS配置的转义问题 #

你的sasl.jaas.config中，password值是完整的Connection String，其中包含多个分号。在properties配置文件中，虽然你用双引号包裹了password，但某些情况下分号可能会被解析为配置项的分隔符，导致JAAS配置失效。

尝试将Connection String中的分号转义为\;，修改后的配置如下：

bootstrap.servers=<my_EH_namespace_here>.servicebus.windows.net:9093
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://<my_EH_namespace_here>.servicebus.windows.net/\;SharedAccessKeyName=xxxxxx\;SharedAccessKey=xxxxxx";

或者，你可以在代码中直接设置JAAS配置，避免properties文件的转义问题：

System.setProperty("java.security.auth.login.config", "/path/to/jaas.conf");

其中jaas.conf内容：

KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="$ConnectionString"
    password="Endpoint=sb://<my_EH_namespace_here>.servicebus.windows.net/;SharedAccessKeyName=xxxxxx;SharedAccessKey=xxxxxx";
};

2. 强制使用TLS 1.2协议 #

Azure Event Hubs要求使用TLS 1.2或更高版本的SSL协议，而Kafka 3.0.1默认可能没有强制指定。在producer.config中添加以下配置，确保客户端使用兼容的SSL协议：

ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2

3. 排查网络和防火墙问题 #

日志中出现了socket connection setup timeout，说明客户端无法在超时时间内建立到Event Hubs的连接：

• 确认你的网络环境允许访问*.servicebus.windows.net:9093端口，没有防火墙或安全组拦截。
• 如果你的环境使用代理，需要在producer.config中添加代理配置：

proxy.host=<your_proxy_host>
proxy.port=<your_proxy_port>
# 如果代理需要认证
proxy.sasl.mechanism=PLAIN
proxy.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<proxy_user>" password="<proxy_pass>";

4. 验证Event Hubs权限和命名空间信息 #

• 确认你的Shared Access Key拥有Send权限（可以在Azure门户的Event Hubs命名空间→共享访问策略中查看）。
• 检查bootstrap.servers中的命名空间名称是否完全正确，没有拼写错误。

5. 临时关闭幂等性排查 #

日志显示你启用了幂等性生产者（Instantiated an idempotent producer），虽然Azure Event Hubs支持幂等性，但偶尔可能存在版本兼容性问题。可以尝试临时关闭幂等性来验证：

enable.idempotence=false
acks=1

如果关闭后能正常连接，再逐步排查幂等性相关的配置（比如transaction.timeout.ms是否符合Event Hubs的要求）。

内容的提问来源于stack exchange，提问作者user468587