-
将REST代理连接到Confluent Cloud尝试连接到Zookeeper
我正在尝试将kafka rest代理连接到融合云。 <pre><code>kafka-rest-start ccloud-kafka-rest.properties </code></pre> -
Avro模式不符合我的json数据?
我正在生成json消息,并尝试使其符合Avro标准。这是我要发送的消息的示例,但是我收到以下错误,我认 -
kafka +融合控制中心+如何获取非企业版
我们按照以下步骤安装了Docker融合控制中心 <pre><code> $ docker run -d \ --name=control-center \ --net=confluent -
Kafka转S3连接器
假设我们在独立模式下使用Kafka S3接收器连接器。 正如写在融合页面上一样,它只有一次交付保证。 我 -
如何使用Spark结构化流配置Confluent的Schema Registry and Avro序列化程序?
我还没有找到任何文档或示例来说明如何将Schema Registry and Avro序列化程序的设置从Confluent传递到Spark结构 -
KSQL SELECT代码有效,但是CREATE TABLE`..` AS SELECT代码返回错误-io.confluent.ksql.util.KsqlStatementException:无法解析列
在KSQL中创建表或流时遇到了问题。 我已经按照官方示例中的说明进行了所有操作,但我不明白为 -
Kafka Connector HDFS Sink 5.3.1无法生成所有JSON记录 kafka-connect-standalone.properties quickstart-hdfs.properties
<h2>使用案例</h2> 我正在阅读一个已经创建的Kafka主题,在该主题上一个单独的集群正在生成一些键和值 -
使用Kafka Connect GCP BigQuery Sink连接器进行表分区
伙计, 我在BigQuery中使用融合连接器进行数据传输。对于每个事件,我都创建了一个Avro模式,该 -
调整Kafka的S3文件大小
我试图深入了解S3连接器的<code>flush.size</code>和<code>rotate.interval.ms</code>配置。我部署了S3连接器,文件大 -
从debezium mongodb连接器收到奇怪的kafka消息
我使用了标题为“ connector”的连接器,通常可以按照官方手册中的描述接收创建/更新/删除消息。 < -
如何将基本身份验证传递给Confluent Schema Registry?
我想从融合的云主题中读取数据,然后再写入另一个主题。 在本地主机上,我没有遇到任何重大 -
使用Kafka连接到InfluxDB从Kafka推送JSON数据时出错
我正在尝试使用<code>JSON</code>将<code>Kafka</code>的数据<code>InfluxDB</code>推送到<code>Kafka-connect</code>。 apache-ka -
如何在Docker环境中访问Kafka Connector(融合日志连接)
我目前正在基于confluent的cp-demo项目与kafka合作。 (<a href="https://github.com/confluentinc/cp-demo" rel="nofollow norefe -
与MariaDB融合连接-JDBC Sink连接器
在我的本地计算机上安装了Confluent Platform,我的所有服务都已启动并正在运行。 我正尝试通过Kafka Connect -
Avro模式GenericRecord缺少密钥
我正在使用<strong> Avro模式</strong>,使用Confluent Kafka客户端从C#应用程序动态向Kafka群集生成消息。数据 -
Kafka Streams API如何从Schema Registry获得正确的架构?
我尝试了解Kafka Streams API如何与Schema Registry一起使用。 我知道您在设置应用程序时必须指定架构 -
producer.poll(0)不会产生任何消息,但是producer.flush()可以工作
当我使用<code>producer.flush()</code>时有效,但根据<a href="https://github.com/confluentinc/confluent-kafka-python/issues/137" -
配置Kafka Streams应用程序以使用Confluent Schema Registry
我有一个Kafka Streams Java应用程序,该应用程序处理Avro Kafka Topic,对数据进行一些更改,并将处理后的结 -
KsqlStatementException:语句未定义架构,并且提供的格式不支持架构推断
我正在使用融合的掌舵图在kubernetes上使用ksql服务器。 <a href="https://github.com/confluentinc/cp-helm-charts/ -
带ElasticsearchSinkConnector的Kafka-是否可以在connetor中定义数据映射?
我将Kafka与以下连接器<code>connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnector</code>一起使用 为 -
卡夫卡没有从Clickhouse检索数据
我必须将数据从Clickhouse推送到Kafka主题,因此我尝试使用Confluent JDBC连接器。 我正在遵循使用MySQL而不是 -
使用kafka将数据从MySQL导入Postgres
我是<code>kafka</code>的新手,我刚刚从github下载了该项目。 问题是MySQL和Postgres之间的同步仅通过一张表才 -
Kafka的最新版本是否不赞成使用Zookeeper?
很长一段时间以来,卡夫卡一直试图摆脱Zookeeper。 Zookeeper的Kafka最新版本是否已弃用? 还是Kafka集群仍 -
融合的JDBC Source Connect在转换中提供了NullPointerException
这真的很奇怪。 在我的数据库中,当我执行此SQL时: <code>select count(*) from mySchema.myTable where some_co -
融合的KSQL“为此主题注册流或表”不会填充主题字段
我有4个主题可以成功地将数据流传输到它们,并且它们的架构看起来不错。 但是,在单击主题>“ -
如何解决Kafka Connect JSONConverter“模式必须包含'type'字段”
我正在尝试向JdbcSink发送消息,消息如下所示 <pre><code>{ "schema": { "type": "struct", -
如何从Kinesis将JSON消息发送到MSK,然后使用kafka connect进行弹性搜索
我已经准备好,流程也正在工作。 我正在使用lambda函数将数据从Kinesis流发送到MSK,消息的格式如下