我有Kinesis流托管在AWS云上，我想将此数据存储到Google云托管的现有Kafka主题中。我不确定连接这两个云
我正在尝试使用<a href="https://debezium.io/documentation/reference/1.2/connectors/mysql.html#configure-the-mysql-connector_debeziu
我正在从Debezium Connector for SQL Server连续收到上述警告，表明我正在使用connect-standalone运行。在某个时刻
我正在尝试创建多个连接器相同的日期数据库，但出现异常
<blockquote>
org.apache.kafka.connect.errors.Conne
我对kafka connect S3接收器连接器有多个疑问
1。我想知道是否可以使用kafka的S3接收器来保存具有多
我正在使用Kafka Connect来流化具有250,000,000条记录的数据库。从源头读取没问题，它在不明显的时间内被
我想通过ksql使用Confluent JDBC Sink Connector来写入ClickHouse数据库。
我有一个将数据写入Kafka主题的c＃应用程
我怎样才能将kafka msg键用作s3连接器中的分区标准，或者
我如何获取密钥并将其也存储在s3对象中
谢谢！
在Mac上，使用以下命令运行独立的Kafka Connect文件流源连接器。并且我在worker.properties文件中设置了<strong>
我已经下载了二进制Kafka文件，然后下载了conector的Jar文件。然后指定连接器jar的路径，并配置连接到mong
我正在尝试使用来自Kafka Connect的JdbcSinkConnector将来自Kafka主题的json消息存储到PostgreSQL表中。 <a href="https:
我有与Kafka（<code>2.1.1-cp1</code>）一起使用的Kafka Connect（版本<code>2.0.1-cp4</code>），运行着大约70个连接器
我有一些使用AvroParquetWriter（来自Kafka Connect S3连接器）编写的Parquet文件。
文件<code>aseg_lat</code>中
我正在与3个kafka代理一起进行多节点Confluent kafka设置，其中存在用于KSQL和架构注册表的单独节点，并在
使用连接器：<a href="https://docs.confluent.io/current/connect/kafka-connect-sftp/source-connector/index.html" rel="nofollow norefe
我是Kafka / Kafka Connect的新手，但是在使用融合的JDBC连接器时遇到了问题。目前，我正在使用Confluent社区d
尝试使用Kafka JDBC接收器复制数据库时出现问题。当我将服务器运行到具有Array数据类型的表时，会出现
我正在做一些大小计算，以计算在Kafka集群中需要多少个分区，并将其消息下沉到ElastiCache for Redis。
<
我将以下JSON发送到kafka（我无法控制发送到kafka的数据）
<pre><code>{
"id":"unique-event-id",
&
我正在使用带有Oracle数据库和jdbc连接器的Kafka Connect。当Kafka Connect从数据库时间戳读取并将其写入主题
