服务器属性 security.inter.broker.protocol=SASL_PLAINTEXT sasl.mechanism.inter.broker.protocol=OAUTHBEARE...

我是Spring Cloud Stream的新手。我无法使用转换功能（消费消息、转换、生成消息）。消费者功能运行良好。 @Bean public Function<String, String>...

我已经在我的 GKE 集群中使用 Strimzi Operator v0.38 和 Kafka Cluster 3.5.1 设置了 kafka 集群。我现在对如何设置 YAML 文件以构建 Kafka...

我有一个简单的应用程序，它将使用来自 topicA 和 topicB 的两个流，将它们转换为 KTables，然后使用外键连接两个表。然后，将联接的结果发送到输出主题。在本地环境中，应用程序运行良好，...

我们将 Avro 方案用于代表“公共”接口的 kafka 主题。现在，当在 Kafka-Streams 应用程序中使用此类主题并调用有状态操作时，将再次自动使用内部名称注册相同的架构。 处理这个问题...

我在Spring Boot应用程序中使用Kafka生产者。 @Component public class MessageProducer { @Value("${topic.name}") ...

我是 Kafka 的新手，我正在尝试使用模式注册表并与 spring 云流绑定消费者集成，我研究了很多，得到了很多参考资料，但没有真正成功。所以你能帮帮我吗 我有一个正在监听 INPUT 绑定的流侦...

我有一个symfony 5.4项目，我想用symfony信使组件实现kafka。 我已经看到了几种方法可以做到这一点，包括这篇文章：Symfony Messenger 使用 Apache Kafka...

我们在 YARN 模式下使用 Spark 流处理来自 Kafka 主题的数据，并想知道是否有人知道如何访问（最好是通过石墨）kafka.consumer 指标？...

我们最近发现我们的 kafka 集群在生产环境中离线了 有四个 broker，replicationFactor 为 2，KAFKA_HEAP_OPTS为 -Xmx30G -Xms30G 服务器.l...