与Kafka经纪人有关的问题
我试图连接到Kafka服务器使用SpringKafka客户端
我正在使用logback。xml。下面是配置。在测试之前，我对Kafka主机和端口进行了硬编码。相同的代码和配置适用于其中一个环境。
<appender name="asyncVerboseKafka"
class="net.logstash.logback.appender.LoggingEventAsyncDisruptorAppender">
<appender name="kafkaVerboseAppender"
class="com.github.danielwegener.logback.kafka.KafkaAppender">
<encoder
class="com.github.danielwegener.logback.kafka.encoding.LayoutKafkaMessageEncoder">
<layout class="ch.qos.logback.classic.PatternLayout">
<pattern>verbose-${springActiveProfile}- %msg</pattern>
</layout>
</encoder>
<topic>${verbosetopic}</topic>
<keyingStrategy
class="com.github.danielwegener.logback.kafka.keying.RoundRobinKeyingStrategy" />
<deliveryStrategy
class="com.github.danielwegener.logback.kafka.delivery.AsynchronousDeliveryStrategy" />
<producerConfig>bootstrap.servers=${kafkaHostName}:${kafkaHostPort}
</producerConfig>
<producerConfig>retries=2</producerConfig>
</appender>
</appender>
共有1个答案
在localhost:9092初始化到节点-1的连接。2017-10-18T15:33:50.952-04:00[APP/PROC/WEB/0][OUT]java.net.连接异常：连接拒绝
表示主机/端口不正确；它正试图连接到本地计算机上的Kafka。
您需要展示如何在属性中配置引导服务器。
-
我有两个< code>kafka 0.10.1的代理集群，之前在我的开发服务器上正确运行< code>zookeeper 3.3.6。 我最近尝试将broker版本升级到最新的，但没有开始。配置没有太大变化 谁能告诉我可能会出什么问题吗。为什么经纪人没有起步？ 已更改服务器。代理服务器1上的属性 已更改代理服务器2上的server.properties 注意： 1.Zookeeper正在两台服务器
-
我正在尝试仅为代理间kerberos配置Kafka代理。然而，由于它似乎也想通过Kerberos连接到Zookeeper，所以我似乎总是遇到错误。我目前还没有设置任何Zookeeper键。 我的Kafka代理 JAAS 配置如下： 服务器属性 我用上述配置得到的错误如下： 换句话说，我只想要经纪人到经纪人的 kerberos 和经纪人 - 动物园管理员的普通SASL_SSL。这可能吗？
-
我知道生产者/消费者需要与经纪人交谈以了解分区的领导者。经纪人与zk交谈以告诉他们加入了集群。 是真的吗 经纪人从zk知道谁是给定分区的负责人 zk发现经纪人离开/死亡。然后重新选举领导人，并向所有经纪人发送新的领导人信息 问题: 为什么我们需要经纪人相互沟通？这只是为了让tehy可以移动分区，或者他们也可以互相查询元数据。如果是这样，元数据交换的例子是什么
-
我们正在使用带有 5 个代理的 Apache Kafka 2.2 版本。我们每天收到 50 数百万个事件，但我们达到了高 kafka CPU 使用率。我们使用默认的生产者/消费者/代理设置。 我对表演有一些疑问； 我们有不同的kafka流应用程序，它们进行聚合或连接操作以携带丰富的消息。我们所有的kafka-流应用程序都包含以下设置： < li >恰好一次:true < li >最小同步副本:3
-
我在Windows子系统Linux上安装了kafka，并开始使用命令服务启动，所有服务都已启动。现在，当我尝试从Windows运行我的kafka-spring应用程序时，它显示以下错误：- 无法建立与节点-1（localhost/127.0.0.1：9092）的连接。经纪人可能不可用。 我的服务器属性是：- 我哪里出错了？？？
-
在Flink中，我执行以下代码： 我推出3次同样的工作。 如果我用一个代理执行这段代码，它工作得很好，但是用3个broke（在3个不同的机器上）只读取一个分区。 null