《kafka》专题
-
Spring-cloud-stream-Kafka生产者前缀每个节点唯一
我想使用输出通道在仅生产者（不在读写过程中）事务中向Kafka主题发送一些东西。我在StackOverflow（生产者端的Spring Cloud stream kafka事务）上阅读了留档和另一个主题。 问题是我需要为每个节点设置唯一的transactionIdPrefix。有什么建议吗？
-
无法使用ChainedKafkaTransaction同步Kafka和MQ事务
我们有一个Spring Boot应用程序，它使用来自IBM MQ的消息进行一些转换，并将结果发布到Kafka主题。我们使用https://spring.io/projects/spring-kafka为了这个。我知道Kafka不支持XA；然而，在文档中，我找到了一些关于使用ChainedKafkaTransactionManager链接多个事务管理器并同步事务的输入。同一文档还提供了一个示例，说明
-
Spring Kafka/Spring Cloud Stream如何保证涉及数据库和Kafka的事务性/原子性？
Spring Kafka和Spring Cloud Stream允许我们创建事务生产者和处理器。我们可以在其中一个示例项目中看到该功能的实际应用：https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/transaction-kafka-samples: 在这个摘录中，有来自Kafka主题的读取、数据库中的写入
-
Spring语义学Kafka
我需要在由以下组件组成的系统中应用事务： Kafka生产者，这是一些外部应用程序，可以发布有关kafka主题的消息。 一个Kafka消费者，这是一个Spring启动应用程序，我在其中配置了kafka侦听器，处理完消息后，需要将其保存到非关系型数据库中。 我看过好几个这样的博客 我没有看到任何明确的例子或博客来实现与我类似的用例中的事务性，即在单个原子事务中生成-处理-写入数据库。我相信这是非常常见
-
处理存储库和Kafka事务
我有一个用例，我需要从一个Kafka主题中消费，做一些工作，生成另一个只有一次语义的Kafka主题，并保存到mongo数据库。看完文档后，我想kafka事务和mongo事务可以同步，但它们仍然是两个不同的事务。在下面的场景中，如果mongo提交失败，是否有方法回滚提交到主题并从消费者处重播的kafka记录。
-
spring cloud stream kafka-功能性方法：在生成墓碑记录时从不调用消费者
问题与https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/455但对于功能性方法 当产生适当的“Foo”（json）时，会调用fo消费者。但是当产生“null”有效负载/墓碑时，永远不会调用消费者函数。 我尝试使用自定义“Convertor”方法的变通方法，该方法正在发挥作用： 然后，食品消费者可以检查有效
-
Spring Cloud Stream Kafka活页夹中的1个输出绑定
在本页中，您不能只进行一次输出 但我只需要使用Spring Cloud Stream Kafka活页夹进行一次输出 那我该怎么办？ 一些文章说使用org.springframework.cloud.stream.function.StreamBridge但它不适合我 我让StreamBridge向Kafka发送主题，但Kafka不会为我的Spring Boot应用程序生成主题 这是我的applic
-
Spring Cloud Stream功能路由器输出尝试绑定到Kafka主题
我正在尝试迁移到Spring Cloud Stream的新函数式编程模型，替换如下的条件StreamListener注释 用类似的东西 具有将通道链接到主题的关联属性 我需要这种间接级别，因为有多种Avro消息类型都到达MyTopic，需要反序列化并以不同的方式路由 这一切都很顺利，我可以按预期使用和路由消息。然而，以这种方式使用functionRouter会产生意想不到的副作用，即当没有可用的主
-
Redis Streams vs Kafka Streams/NAT
Redis团队为Redis 5.0引入了新的Streams数据类型。由于Streams从第一视角看起来像Kafka主题，因此似乎很难找到使用它的真实世界示例。 在streams intro中，我们与Kafka streams进行了比较： 运行时消费者组处理。例如，如果三个消费者中的一个永久失败，Redis将继续服务第一个和第二个，因为现在我们只有两个逻辑分区（消费者）。 Redis流更快。他们从内
-
Kafka：连接器的插件类加载器错误：“org”。阿帕奇。Kafka。连接文件找不到FileStreamSourceConnector我正在windows计算机上使用Kafka，并尝试使用文件源连接器生成从文件到Kafka主题的内容。首先我启动了zookeeper，然后在启动Kafka Standalone Connector时启动了Kafka server（步骤3），我收到了很多警告，ReflectionsException 我对此没有什么疑问： 1。我需要添加一些jar文件吗 2。在libs文件夹下的Kafka dir中有一
-
无法在Windows 10上启动Kafka服务器-Kafka的日志目录（和子目录）应仅包含Kafka主题数据
按照《初学者学习Apache Kafka》第28课中的说明，我的课程将启动zookeeper，然后在Windows 10上启动Kafka服务器代理。Zookeeper在端口2181上运行良好： ... 信息绑定到端口0.0.0.0/0.0.0.0:2181 但在将bat文件添加到path后，运行kafka服务器不起作用： ... 错误加载日志时，其中一个线程出错：org。阿帕奇。Kafka。常见的
-
Kafka：无法找到或加载主类安装窗口
我正在尝试在我的计算机上安装Apache Kafka。我下载了最新版本2.12-2.0.0。在我收到的\bin\Windows目录中键入“..\zookeeper-server-start.bat../../config/zookeeper.properties”后，我想在Windows上运行它： 错误：找不到或加载主类Files\Java\jdk-10.0.1\lib； C：\Program起因
-
Spring boot REST服务在控制器内的运行时设置Kafka主题属性
我对春靴和Kafka还不熟悉。我有一个简单的rest服务，调用该服务时会使用来自kafka主题的消息。有一个自定义配置类controller。想知道如何在运行时设置属性，例如MAX\u POLL\u RECORDS\u CONFIG、AUTO\u OFFSET\u RESET\u CONFIG等。我看到KafkaConfig只在启动时执行。如何在运行时设置上述属性，也就是说，基于一些查询参数想要设
-
无法列出Kafka主题
我正在运行ansible在一台服务器上安装Kafka。（在Dev env上，独立设置）但我的剧本在列出Kafka主题的任务列表时失败了。下面是日志。 Journal alctl-fu动物园管理员 /opt/kafka/kafka\u 2.12-2.2.2/config/zookeeper。属性 动物园管理员。服务
-
在kafka 2.12的win 10中启动动物园管理员时出错在windows 10操作系统中尝试启动zookeeper时，我遇到了一个错误\Apache此时出现了意外错误 我已经使用了带有反冲和正斜杠的命令没有用 E： \kafka\kafka\u 2.12-2.2.0\kafka\u 2.12-2.2.0\bin\windows \Apache对此感到意外