Apache Kafka Connect是Apache Kafka与其他数据系统之间可扩展且可靠的流数据的工具。 - https://kafka.apache.org/documentation.html#connect
我想使用下面的连接器配置将多个表数据发布到同一个Kafka主题，但我看到下面的异常异常引起：io.confluent.kafka.schemaregistry.client.rest ....
无法连接并描述Kafka群集。检查worker的代理连接和安全属性
安装：kafka_2.11-2.1.0和zookeeper-3.4.13运行：bin / zookeeper-server-start.sh config / zookeeper.properties bin / kafka-server-start.sh config / server.properties运行连接器：bin /连接-...
我正在尝试编写一个Kafka连接器来从Facebook获取数据。问题是，如何通过他们的API从Facebook获取数据，而不超过由...提供的API命中限制
要阻止Kafka Connect Worker杀死哪个进程？
我想杀死我的Kafka Connect分布式工作者，但我无法（或者我不知道如何）确定在linux中运行的哪个进程是该工作者。运行ps aux |时grep worker我确实看到了......
我正在尝试使用递增的摄取来生成有关更新mysql中的表的主题的消息。它使用时间戳工作，但似乎没有使用递增列模式。当我 ...
即使在指定quote.sql.identifiers = NEVER之后，table.whitelist也是区分大小写的
我使用JDBC源连接器从oracle到kafka主题摄取数据。我有用小写字母创建的kafka主题，所以我必须指定table.whitelist = table_name（小例）。由...来...
我是Kafka的新手，我使用kafka通过logstash收集netflow（没关系），我想将数据从kafka发送到elasticsearch，但是有一些问题。我的问题是如何连接......
我看到连接器的状态，我有这个异常org.apache.kafka.connect.errors.ConnectException：此worker中已存在任务：* org.apache.kafka中连接器的名称* ....
我正在使用带有Kafka流的CCC，该流由Debezium的Postgres连接器填充。我正在使用以下docker-compose.yml：version：'2'服务：zookeeper-1：image：...
如何为Kafka Connect和Spark注册和使用AVRO Schema？
我不太明白如何在jdbc源或接收器连接器中注册模式以使用它并在Spark中读取数据这是我想用来从...检索记录的avro模式
如何在Java中集成Kafka connect和Kafka producer，以便我可以实时读取CSV文件？我很难找到与此相关的任何来源。现在我正在使用scala-ide来......
使用jdbc-sink-connector中的kafka SMT将avro架构中的Map字段转换为字符串？
我有一个定义如下的avro模式：[{“namespace”：“com.fun.message”，“type”：“record”，“name”：“FileData”，“doc”：“FileData的Avro Schema”， “田地”：[{“......
Kafka AVRO Consumer：MySQL Decimal到Java Decimal
我试图从MySQL表中消耗记录，其中包含3列（Axis，Price，lastname）及其数据类型（int，decimal（14,4），varchar（50））。我插入了一条有...的记录
我使用的是原生的apache kafka而不是融合版的kafka。我正在使用kafka jdbc连接器插件。我打算提出一个断点并通过我的IDE（intelliJ）进行检查。怎么做 ...
这是开发人员指南关于动态连接器的说法https://docs.confluent.io/current/connect/devguide.html#dynamic-connectors并非所有连接器都有一组静态分区，......
我找不到明确的答案，所以我想我会问专家。 Kafka如何观察和检测给定来源中的哪些数据发生了变化？例如，在关系数据库中？投票......
使用kafka connect配置debezium mysql连接器失败
我正在使用kafka 2.0与kafka连接在分布式模式下运行并尝试配置debezium mysql连接器但得到错误HTTP / 1.1 500内部服务器错误服务器：squid Mime-Version：1.0 ...
我正在使用kafka 0.11。我在kafka-streams-0.11.0.0.jar中找不到StoreBuilder类。知道这是什么问题吗？
我尝试连接到几个数据库，包括MySQL和MSSQL，我没有问题。但是，当我试图连接到某个远程MySQL数据库时（可以只访问我公司的...
我目前正在研究Kafka Connect将我们的一些数据库传输到数据湖。为了测试Kafka Connect我已经在我们的项目数据库之一设置了一个数据库。到目前为止一切都很好。下一个 ...