Kafka流-仅一次配置
我试图使用kafka流库只使用一次kafka的功能。我只将proessing.guarantee配置为exactly_once。与此同时，需要将事务状态存储在内部主题（__transaction_state）中。
我的问题是，如何定制主题的名称？如果kafka集群由多个消费者共享，那么每个消费者是否需要不同的事务管理主题？
谢谢你，墨蒂
共有1个答案
你不需要担心主题\uuuu transaction\u state——它是一个自动为你创建的内部主题——你不需要手动创建它，它总是有这个名称（无法自定义名称）。它将用于所有使用事务的生产者。
-
我有 2 个Kafka集群。群集 A 和群集 B。这些集群是完全独立的。我有一个Spring启动应用程序，它侦听集群 A 上的主题，转换事件，然后将其生成到集群 B 上。我只需要一次，因为这些是金融事件。我注意到，对于我当前的应用程序，我有时会遇到重复的情况，也会错过一些事件。我试图尽我所能只实现一次。其中一篇帖子说，与Spring启动相比，flink将是一个更好的选择。我应该搬到闪光灯吗？请参阅
-
我的目标是从主题A消费，做一些处理和生产到主题B，作为单个原子动作。要做到这一点，我有两种选择： null 我已成功验证选项#1。所谓成功，是指如果我的处理失败（抛出IllegalArgumentException），来自主题A的已消费消息将继续被KafKalistener消费。这是我所期望的，因为没有提交偏移量，而使用了DefaultAfterRollbackProcessor。 我希望看到相同
-
我在一些关于堆栈溢出的答案中看到，通常在web中也看到，Kafka不支持消费确认，或者消费一次就很难实现。 在以下作为示例的条目中，有没有理由使用RabbitMQ而不是Kafka？，我可以读到以下语句： RabbitMQ将保留已消耗/已确认/未确认消息的所有状态，而Kafka则不保留 或 有人能解释一下为什么Kafka的“一次消费保证”很难实现吗？这与Kafka和RabbitMQ等其他更传统的消息
-
当我只打开一次处理时，我会得到以下错误。注意：我们的应用程序非常安全，我们只允许Kafka用户和消费者访问他们明确需要的资源。 只有一次处理kafka流是否在所有流任务中使用每个流任务的消费者组而不是消费者组？
-
扬尼克
-
在Kafka Streams中添加压缩配置，类似于此链接： 但是我在日志中看到以下警告消息： 这个设置不受尊重吗？是不是表达得不好？