《寒武纪》专题

我正在尝试更改storm中的wordcount示例：我不想显示结果，而是想将其发送到kafka集群。以下是构建拓扑的代码： 正如你所看到的，我想把wordCountbolt的结果发送到Kafka主题。然而，我得到了这个例外： 7793[Thread-18-forwardToKafka-executor[2 2]]信息o.a.s.d.executor-BOLT失败任务：2次：-1元组：源：字计数器：

我们的集群中有带有 Ambari GUI 的 Hadoop 集群版本 2.6.4，我们有 3 台 Kafka 机器，它们是独立的机器，而 3 台 Zookeper 服务器安装在其他机器上 - master01/02/03 其中一台Kafka机器出现了一个奇怪的问题，而其他Kafka设备没有这个问题 问题是，当我们在几分钟后启动Kafka经纪人时，它会崩溃 以下是日志： 出自Kafka.呃 从日志的

但显示错误 线程“main”java.time.format.dateTimeParseException:Text'2021-10-06 0:29:43“无法在索引11处解析，位于java.base/java.time.format.dateTimeFormatter.parseresolved0(DateTimeFormatter.java:2052)，java.base/java.time.

我们正在运行活动 MQ 5.6.0。在我们的测试环境中，我们有 3 个代理在静态网络中运行。下面是当前方案。我们有6个消费者随机连接到3个经纪人。一个经纪人有3个消费者，第二个有2个，第三个有1个。当我们向队列堆积消息时，我们看到消息积压在第三个代理上，有 1 个使用者，另外两个代理没有获得任何积压，其余 5 个使用者处于空闲状态。 在下面，您将找到我们所有一个代理（dev.queue01）的配置

我试图解析一个字符串，下面的表单2010-10-12-18-43-55到当前时区自纪元以来的秒。这是我试过的 我。

我是使用ActiveMQ的新手，正在试图理解经纪人网络是如何工作的。我已经阅读了activemq文档，并浏览了互联网上的一些文章，如http://www . jakubkorab . net/2011/11/understanding-ActiveMQ-broker-networks . html 我在本地Windows桌面上设置了以下内容。有2台tomcat服务器分别运行在8080和9080上，

我有一个情况，我可以访问一个作为.json文件的合同，但它还没有发布，这可能需要一段时间。我想开始为它编写验证测试，所以是否考虑手动粘贴这个文件到pact/文件夹下，并连接到它，而不是一个在线代理？我想我以前在什么地方见过这样的事。这真的可能吗？如果可以，请给我一个样品好吗？谢谢.

我试图连接到Kafka服务器使用SpringKafka客户端 我正在使用logback。xml。下面是配置。在测试之前，我对Kafka主机和端口进行了硬编码。相同的代码和配置适用于其中一个环境。

我有两个kafka代理，使用SSL的kafka-0和使用PLAINTEXT的kafka-1（使用Docker映像部署）。 我需要设置security.inter.broker.protocol，以便kafka-0和kafka-1可以相互对话。当我将两个代理都设置为明文时，kafka-0会给出以下错误: hafka-0的广告监听器是 同时，如果我将两个代理的协议都设置为SSL，kafka-1会抱怨:

当尝试在 CentOS 上使用 Python 客户端本地连接到 Kafka 0.10.0.0 时，我有一个非常奇怪的问题。 我的连接选项非常简单且默认： 当我在Kafka的服务器中手动设置侦听器选项时。属性文件，如： 我得到了kafka.errors。NoBrokersAvailable，尽管我仍然可以使用curl或其他linux工具轻松连接到Kafka代理服务器。 无广告。侦听器或其他不推荐使用

我正在尝试仅为代理间kerberos配置Kafka代理。然而，由于它似乎也想通过Kerberos连接到Zookeeper，所以我似乎总是遇到错误。我目前还没有设置任何Zookeeper键。 我的Kafka代理 JAAS 配置如下： 服务器属性 我用上述配置得到的错误如下： 换句话说，我只想要经纪人到经纪人的 kerberos 和经纪人 - 动物园管理员的普通SASL_SSL。这可能吗？

为什么消费者连接到zookeeper来检索分区位置？kafka制作者必须连接到其中一个代理来检索元数据。 我的观点是，当每个经纪人都已经有了所有必要的元数据来告诉生产者发送信息的位置时，动物园管理员到底有什么用？经纪人不能把同样的信息发送给消费者吗？ 我可以理解为什么经纪人拥有元数据，而不必在每次向他们发送新消息时都与动物园管理员建立连接。动物园管理员有什么功能是我错过的吗？我发现很难想到为什么在

Kafka初学者和融合包。我想启动多个代理，以便了解主题。可以通过此设置完成- 此设置可以在服务器配置文件中定义，也可以在脚本中定义。 但是我该如何运行它们呢？。如果我只是向引导服务器添加多个endpoint，就会出现以下错误: Java . lang . illegalargumentexception:要求失败:每个侦听器必须有不同的名称，listeners: PLAINTEXT://:909

我有两个< code>kafka 0.10.1的代理集群，之前在我的开发服务器上正确运行< code>zookeeper 3.3.6。 我最近尝试将broker版本升级到最新的，但没有开始。配置没有太大变化 谁能告诉我可能会出什么问题吗。为什么经纪人没有起步？ 已更改服务器。代理服务器1上的属性 已更改代理服务器2上的server.properties 注意： 1.Zookeeper正在两台服务器

我在单节点中运行kafka，我想看到kafka生产者行为，当我关闭我的kafka代理，然后我在几秒钟内重新启动我的代理，所以我创建Spring启动程序，我可能会发送1000个客户JSON对象并打印每次发送的JSON对象的偏移量。我的应用程序工作正常，但是当我关闭我的kafka代理并在几秒钟后我重新启动我的代理时，我的生产者返回以正常发送来自最新偏移量的对象。对于我的例子，当偏移量= 983在控制台