配置Kafka侦听器
我有一个关于正确配置kafka侦听器属性的问题-侦听器和advertised.listers。
在我的配置中，我设置了以下道具：
listeners=SASL_PLAINTEXT://:9092
advertised.listeners=SASL_PLAINTEXT://u-kafkatst-kafkadev-5.sd.xxx.com:9092
客户端使用 u-kafkatst-kafkadev-5.sd.xxx.com:9092 进行连接。我是否需要在侦听器和广告侦听器中具有相同的值。这里 u-kafkatst-kafkadev-5.sd.xxx.com 是指向运行 kafka 代理的主机的 dns 记录。
在什么情况下，我希望它们保持不变和不同？
谢谢！
共有1个答案
如果您要执行除直接连接到同一网络上的代理以外的任何操作，则 advertised.listen 属性非常重要。如果您使用的是 Docker、库伯内特、IaaS（AWS、GCP 等），那么您需要公开外部地址，以便客户端知道要连接到的位置。
这篇文章对此进行了深入的解释。
-
要运行Kafka，需要在文件。有两种设置我不理解。 有人可以解释侦听器和广告侦听器属性之间的区别吗？ 留档说： 侦听器：套接字服务器侦听的地址。 和 advertised.listeners：主机名和端口代理将向生产者和消费者做广告。 我什么时候必须使用哪个设置？
-
我有一个配置文件作为库伯内特斯ConfigMap数据部分的一部分。每当配置文件（ConfigMap data：）的内容发生变化时，应该会有一些触发器/侦听器导致一些调用。（作为此调用的一部分，我需要实现一些代码来重新启动一些服务对象）。 是否有一些可用的库伯内特斯配置可用于为ConfigMap配置此侦听器？。 ConfigMap示例：
-
我正在Wildfly 9.0.1的KeyClope中配置一个事件侦听器。我创造了一个。jar有两个类，实现了一个提供者，如KeyClope在他的github示例中解释的那样。 在本例中，keydape人员解释说，有必要注册提供者编辑“standalone/configuration/standalone.xml”并将模块添加到providers元素中。我在标签“subsystem”中对这个定义进行
-
问题内容： 我正在使用EJB 3.1，并且想配置一个MDB来侦听多个队列。 我更喜欢通过XML定义队列名称，而其他通过注释定义。 能做到吗？ 问题答案： 实例化后，MDB只能侦听在其目标ActivationConfigProperty中指定的资源，但是您 可以 为同一MDB创建具有不同目标的多个实例（在您的情况下为队列）。 在ejb-jar.xml中创建两个条目，它们具有不同的目的地和ejb-na
-
我是Kafka侦探的新手。目前我遇到了一个问题，span在MessageListenerMethodInterceptor中创建了一个在KafkaListener上触发的拦截器，但如果出现异常，我们将在ErrorHandler中丢失spanId和traceId。是否可以将sleuth配置为在KafkaMessageListenerContainer中启动span？
-
我正在尝试在WebLogic 10.3.5上创建一个MDB（EJB 3.0）。在外部AMQ服务器上监听队列。经过大量工作和教程组合，我在webLogic上部署时遇到以下错误。 [EJB:015027]消息驱动的EJB是事务性的，但JNDI名称ActiveMQXAConnectionFactory引用的JMS连接工厂不是JMS XA连接工厂。 以下是我所做工作的简要介绍： 我已经将相应的库添加到我的