我正在使用我们的 Confluent (5.5.1) 安装定义 Camel S3 源连接器。创建连接器并将状态检查为“正在运行”后
我在本地使用 Confluent Platform 5.5.0，使用名为 Debezium 的开源工具捕获数据库中的更改。由于 max.request.size
我是 Kafka 的新手，想了解 apache Kafka 在以下场景中的行为。
考虑我有 3 个主题：
<ul>
<li>分区 3</
因为我在 neo4j 和 confluent kafka 工作，所以我有以下问题。
这些是我在neo4j.conf中做的事情
<pre><cod
我正在使用来自 github 的 confluent-platform(cp-all-in-one) docker 镜像
<a href="https://github.com/confluentinc/cp-all-in-one/t
在 COnfluent Elasticsearch Sink 连接器中，我试图从两个不同的主题写入相同的 Elasticsearch 索引。第一个主题
我一直在寻找有关 Kafka Connect 连接器高可用性部署的具体信息，但一无所获。
就我而言，我使用 <a
我在 JDBC 源连接器 table.whitelist 中列出了 5 个表。它们是从 PostgreSQL 并行同步到 Kafka 还是一张一张表同
我使用 debezium 连接器为 MS SQL 尝试了 kafka 连接转换谓词示例，但遇到了 kafka 连接文档的问题。两个文档
我一直在通读 <a href="https://docs.confluent.io/platform/current/multi-dc-deployments/replicator/replicator-failover.html" rel="nof
我正在开发一个可以生成 kafka 消息的系统。这些消息将被组织成或多或少代表数据库表的主题。许多这
<strong>broker/docker-compose.yml</strong>
<pre><code>---
version: '2'
services:
zookeeper:
image: confluentinc/cp-zoo
您好，我目前正在设置带有关联数据库的 kafka 接收器连接器。但是，我的 avro 文件包含字段计数作为整
Confluent 的 MySQL 接收器连接器是否有其他选择？
我对 kafka 还很陌生，并试图在一个唯一的键上加入一堆流。我有两个不同的流，我可以从听两个不同的
这里有一篇关于缩放 <a href="https://www.confluent.io/blog/how-real-time-stream-processing-safely-scales-with-ksqldb/" rel="nofol
我有一个已经工作了几个月的 Kafka 消费者，但现在我收到以下信息：
<em>Broker：组授权失败</em>
环
<P>我有一个卡夫卡-主题和我想与AVRO数据给它（当前在JSON）。我知道“正确”的方式做到这一点是使用方
我们的 Kafka 设置包括 AWS MSK 上的代理、AWS EKS pod 上的 Confluent Kafka Connect (confluentinc/cp-kafka-connect:5.5.1)。</
在 JSONSchema 中使用部分开放的内容模型。这意味着主题会接受一些必填字段（在属性中定义）和非必填
