在kafka代理中配置listeners属性的正确方法
我们有5个经纪人的集群，并配置了如下server.properties
listeners=PLAINTEXT://kafka1:9092
我在所有经纪人、生产者和消费者的/etc/hosts文件中添加了如下条目
“私人：IP:kafka:broker1”kafka1
这在很大程度上适用于我们，我们在配置新消费者时不必记住引导服务器的私有IP。
我想知道这是不是Kafka经纪人和客户之间沟通的好方法？
因为我不是DevOps的人，我不确定这是否会潜在地导致隐藏的问题。请对此进行评论。
另一件事是，我看到Kafka经纪人和客户之间的随机脱节导致不同的问题。我只是想清除这在某种程度上引起问题的可能性。
共有1个答案
我在/etc/hosts文件中添加了所有代理、生产者和消费者的条目，如下所示
这是不好的。请不要这样做
如果无法单独通过bootstrap.servers属性解析主机，则侦听器不正确。
请阅读Kafka听众的解释，了解您想要的所有细节。
在配置新消费者时，我们不必记住引导服务器的私有IP
您可以使用服务发现工具来适应此问题。领事是一个受欢迎的，那么你只需指向kafka.service.consul：9092，它就通过DNS的魔力“工作”。
或者，您应该在已经预先配置了至少引导服务器设置的Kafka客户端库上进行标准化，然后在内部将此“库”发布给开发人员以供使用
-
问题内容： 我们正在使用类似于系统规则的方法来处理JUnit 4测试中的（系统）属性。这样做的主要原因是每次测试后都要清理环境，以便其他测试不会无意间依赖于可能的副作用。 由于JUnit 5已发布，所以我想知道是否存在“ JUnit 5方法”吗？ 问题答案： 有JUnit 5 Pioneer，一个“ JUnit 5扩展包”。它带有和。从文档： 的和注释可用于清除，分别为测试执行系统设置属性的值。这
-
问题内容： 我正在尝试将log4j配置为使用，但我不断收到中继访问被拒绝的错误。在笔记本电脑上直接从共享托管环境执行代码时，出现此错误。 这是相关的配置： 如果改用，则会收到身份验证错误。我的主机位于DreamHost上，因此如果有人使用DreamHost电子邮件帐户设置了log4j，则可获赠积分。 问题答案： 原来我只是把属性都弄错了。应该：
-
TLS加密：已启用 客户与经纪人之间 TLS加密：已启用 在此之后，我使用以下命令启动了Kafka rest代理： 但是，当我试图通过从Postman:Post:http://ip_of_ec2instance:8082/topics/TestTopic调用服务将事件放到TestTopic上时，我得到了500个错误。但是在EC2实例中，我可以看到错误： 我还可以在ProducerConfig值中看
-
问题内容： 我有点问题。我需要在此拦截器中调用每个请求的postHandle方法： 所以我将这一行放入servlet配置中，一切正常。 但是现在我必须更改配置和使用 通过这种配置，我在postHandle方法中的modelAndView上得到了一系列空指针异常，因为每个请求多次调用postHandle方法。 使用此配置，它可以工作，但仅适用于请求serverAdress /任何东西。对于请求ser
-
我已经制作了一个列[日期，名称，性别和年龄]的表，并将其链接到一个代理。我想使用选择输出框将具有特定名称（属性）的代理分离到特定块。我已经从表中创建了名称作为代理的参数。但是当我试图将条件放入选择输出块（（人员）代理）时。name==“ahmed”或agent.name==“ahmed”没有条件为真，所有条件都被绕过到假端口。 我也尝试在代理中声明变量，并尝试将其传递select_output但结
-
问题内容： 有一个像这样的简单Python类： 我想检查以下约束： “说明不能为空” “值必须大于零” 我应该： 1.在创建垃圾邮件对象之前验证数据吗？ 2.检查方法上的数据？ 3.在Spam类上创建一个方法，并使用spam.isValid（）进行调用？ 4.在Spam类上创建一个静态方法，并使用Spam.isValid（description，value）进行调用？ 5.检查二传手声明中的数据？