我正在使用BigQuery对Postgres数据库进行存储，并且可以正常工作，但是当我插入，更新或删除一行（Postgre

我们是基础架构团队，他们想要维护Kafka集群。在这种情况下，我们计划为开发人员提供Kafka环境。我的

<pre><code>Using standalone mode, to transfer data from Kafka to JDBC . Able to put data from kafka to file but not in mysql database. All k

我的本​​地系统中正在运行kafka和kafka connect，activemq也在本地中运行。现在，我必须通过kafka connect来

我是<a href="https://en.wikipedia.org/wiki/Apache_Kafka" rel="nofollow noreferrer">Kafka</a>的初学者。因此，在学习它的过

我正在尝试为具有3个节点的Kafka Connect集群设置第3个工作线程。 worker在第3个节点上正常运行，我可以进

使用Kafka Connect <a href="https://kafka.apache.org/26/javadoc/org/apache/kafka/connect/data/SchemaBuilder.html" rel="nofollow noreferr

我们正在尝试在AWS上设置Kafka。我们计划将AWS提供的MSK用于我们的Kafka。但是，我们需要分别安装Schema Reg

我正在尝试设置一个Kafka连接器，用于使用SMT接收器到本地文件系统以过滤一些消息。 Kafka主题中的消息

我的行为我不知道该如何修改。 我正在测试s3 Kafka同步连接器，而我的主题中的数据很少。 此刻，

在标准/自定义kafkaconnect接收器中，我们如何指定它仅应使用来自kafka主题的read_comitted消息。我可以在此

我们刚开始使用Kafka（Confluent平台），并且有一个使用JDBC源连接器的项目。通过这种方法，当数据存储

我已阅读<a href="https://docs.confluent.io/current/connect/managing/monitoring.html" rel="nofollow noreferrer">https://docs.confluent

我在另一台机器上有一个3节点的Kafka集群，在其中我无法通过Spring Boot应用程序远程连接和使用消息。我

我能够通过Postgres成功连接Debezium CDC + Kafka。我还能够通过JDBC Kafka连接回postgresql db，在简单的表格书（

kafka融合连接器出现问题，连接器在一段时间后停止工作，当我查看连接器的日志文件时没有错误。

我有Kafka消息，并且我正在使用Kafka Connect接收器连接器将消息移至s3。 Tha消息具有2个浮点字段<code>amount<

我想将一组SMT（单个消息转换）应用于一个主题。 我有以下配置。 <pre><code> connector.class: io.debez

很抱歉，我的问题到处都是，但是我是Apache Kafka的新手，目前我正尝试使用Windows OS将数据从Teradata表（

我已经启动了zookeeper，kafka服务器，kafka生产者和kafka消费者，并且我把从confluent下载的jdbc sql连接器jar放