我试图运行具有5个工作人员和2个接收器连接器的Kafka Connect分布式集群。一个连接器配置了最大任务，

是否可以指定debezium postgres连接器从特定记录读取，而不是从postgres表的开头读取。我们正在debezium kafka

我们运行了Debezium MySQL连接器，其中历史记录主题已经具有无限的保留期。但是很奇怪，连接器突然失败

从<a href="https://docs.confluent.io/current/quickstart/ce-docker-quickstart.html" rel="nofollow noreferrer">Confluent Platform (Docker)

为了了解CDC管道的模式演变，我试图将头绪围绕在以下<a href="https://docs.confluent.io/3.0.0/connect/connect-jdbc/doc

我的项目中有一个要求，在该项目中，必须在单击REST服务后获取数据。是否有任何Kafka连接器可以完成

Kafka消息未插入到postgresql数据库中。我可以在使用者中看到消息，但消息未插入表中。任何建议都会有

我正在以分发模式启动Kafka connect，但收到以下错误。 在其他开发集群上也可以正常工作，但是，只有在

我想使用现成的kafka连接器从REST API中获取数据。我在汇合的集线器上找到kafka-connect-http连接器，但该连

在AWS Fargate中使用Debezium postgresql源连接器运行confluentinc / cp-kafka-connect：5.5.1。 在第一次运行时，没

在使用docker时，尝试使用postgres debezium连接器运行kafka connect时遇到问题，它找不到位于<code>debezium-core</co

我用Java生成数据并将其下沉到Kafka主题，之后我希望该数据沉入MongoDB。 当我通过JAVA将数据作为JSON发送

我试图按照Debezium博客<a href="https://debezium.io/blog/2017/09/25/streaming-to-another-database" rel="nofollow noreferrer">here</

Am正在尝试将数据从一个流文件传输到另一文件。它运行得更早，突然提供了错误<code>ERROR Stopping due to e

我正在研究一种情况，我想要写入的主题与写入的数据库表之间存在多对一的关系。数据源提供了有关

我正在探索<code>kafka-connect</code>，使用<a href="https://docs.confluent.io/current/connect/kafka-connect-spooldir/connectors/cs

我尝试使用Confluent BigQuerySinkConnector创建从Kafka到BigQuery数据管道。测试环境是一个<a href="https://i.stack.imgur

我一直关注<a href="https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/" rel="nofollo

我尝试使用有关Kafka主题的JSON数据创建到BigQuery的数据管道。测试环境是一个cp-all-in-one docker容器。我添

我正在尝试使用cratedb作为接收器运行jdbc接收器连接，如<a href="https://crate.io/docs/crate/howtos/en/latest/integrati