Google并没有帮助我，所以我想问你。我有很多关于Kafka的话题，我看过很多关于Java堆内存的文章，等等
我正在使用Debezium和kafka connect。我需要从下面的有效负载中提取“ listid”，并能够将其分配给kafka消息
如何使用Kafka Connect从kafka消息中检索传入的标头，以使用MongoDB Sink Connector到mongodb将它们存储为其他数据
我想拥有一个kafka连接代理集群，可用于从不同来源提取数据并将其推送到存储在同一集群的不同节点中
我正在尝试在Intellij IDE中设置kafka connect，以便我可以了解它的工作方式，特别是它在插件路径中加载jar
这可能是一个非常简单的问题，所以我会提前道歉。
我要为kafka主题（此处为conf文件）添加s3接收器连
我正在尝试建立一个连接器，该连接器从SQL Server提取数据以与apache kafka一起使用。我已经使用docker-compos
我已经在Kafka Connect中设置了JDBC Oracle Source Connector，并且在Oracle表中有一个timestamp列，其值设置为日期格
我为3节点Kafka集群设置了ACL，并且能够通过生产者控制台和使用者控制台发送和接收主题。现在，我想
我有以下设置-Zookeeper，kafka，架构注册表和kafka-connect。它们全都在kubernetes中的不同Pod中运行。我想将一
我们有一个托管的Kafka设置（Confluent平台，Kafka connect 5.5.1），可通过8到10个连接器流式传输来自约40个主
我在使用mirrormaker 2时遇到问题。
Mirrormaker 2基于Kafka Connect框架，可以将其视为Kafka源连接器和接收
我正在尝试创建一个使用protobuf值转换器的kafka接收器连接器。我已经有了使用JSON的此配置的版本，但是
我们有一个（融合）托管的kafka安装，其中包含5个代理和2个连接器主机。我有两个主题，尽管反复地启
标题怎么说，有一种方法可以设置Kafka JDBC Source连接器从数据库读取的记录的主键？
这是<code>connect
下面的代码是我的Kafka-connect-JDBC和MySQL驱动程序的Dockerfile
<pre><code>FROM debezium/connect:1.3
ENV KAFKA_CONNECT_J
尝试使用简单的文件接收器连接器从主题中提取数据。生成的文件不包含事件密钥，并且我无法找到启
我是Kafka的新手，我想看看是否可以使用Kafka将MongoDb数据与另一个系统同步。
我的设置：
<ol>
<li
我正在使用Kafka JDBC Sink连接器将数据从kafka主题提取到MariaDB中。我的kafka接收器连接器之一导致生产服务
我有一个Web服务器，该服务器在请求后接收一些事件，我想使用Kafka Streams进行处理。我可以使用哪个Sour
