我正在订阅一个主题并尝试使用消息，但是，尽管我看到使用者已订阅该主题，但是使用consumer.consume（c
我想通过命令行参数提供组ID，但尝试此操作时出现以下错误。
<pre><code>Failed to start bean 'org.springfr
我有一个Java使用方使用broker1：9092连接到kafka集群（3个代理）。然后，客户端将接收包含集群中代理的
这是我要转换为Avro模式的Java枚举：
<pre><code>public enum ApplicationCode {
APP_A("MY-APP-A"),
APP_B(
我正在使用kafka-python == 2.0.1
producer.py
<pre><code>def queue(self, key, value):
self.producer.send(
我正在将Spring Boot从<code>1.5</code>升级到<code>2.3</code>，将kafka从<code>0.11.0.3</code>升级到<code>2.5.0</code>，spark
我的项目中有一个要求，在该项目中，必须在单击REST服务后获取数据。是否有任何Kafka连接器可以完成
我的应用程序具有多个springboot服务，这些服务在application.yaml中配置了kafka生产者和/或使用者。同样，我
我有一个kafka集群或3个在AWS EC2实例上运行的代理。但是，由于Kafka生成了日志，因此这些计算机上的磁
<strong>能否请某人澄清我对Ignite缓存的疑问。我已经检查了Ignite文档，但未提及这些内容：</strong>
<o
Kafka消息未插入到postgresql数据库中。我可以在使用者中看到消息，但消息未插入表中。任何建议都会有
Confluent Control Center似乎是模块化的，但是我还没有找到有关如何构建自己的插件以进行Kafka自定义管理
运行单个Zookeeper实例安全吗？我有一台zookeeper服务器和3个kafka代理，它们构成了我的集群。我想让Zookeepe
是否可以从Kafka的消费者组中删除组成员，而不必删除整个组？
我正在将kafka 2.3.1（server）与spring-kafka 2.2.14和kafka-clients 2.0.1一起使用。
我有一个包含10个分区的主
我从一个源系统收到了以下事件有效负载
为以下json有效负载创建了Stream1
事件JSON 1
<pre><c
Confluent Platform版本5.4.2
在Kubernetes中部署了3个Broker设置
在一个主题中，我们有1024个分区，在
我正在尝试将Flink连接到Druid。
但是，我不知道该怎么做。
在此<a href="https://ci.apache.org/projects
我们尝试将当前的Kafka Server集成到我们的SQL Server表中，但是缺少执行该操作的示例。我们想要的过程是
因此，我有一种情况想与我所订阅主题的模式相匹配。我主题的结构是3部分的“ part1.part2.part3”，例如D
