当前ksql的状态使得很难理解哪个版本支持/拒绝/强制/可选的功能。没有明确的版本引用的Confluent文档并
使用下面的代码，我尝试使用asyncio启动2个无限循环：
<pre><code>async def do_job_1():
while True :
pri
我正在使用数据库源连接器将数据从Postgres数据库表移至Kafka主题。我有一个订单表，该表具有一个使用c
我当地的win10 WSL退赛，
在ubuntu中，我已经安装了spark3.0.0，融合平台5.5.1（手动下载）
当我尝试运
我正在通过Kafka connect将Debezium连接器用于Postgres。
对于由连接器写入Kafka的插入行事件，我需要有
我有一个主题，我正在通过以下格式发送json：
<pre><code> {
"schema": {
"type": "string"
我是Kafka和Avro的新手，我一直在阅读Avro如何提供一个不错的maven实用工具<code>avro-maven-plugin</code>来生成Av
我正在尝试在Amazon EKS上部署融合服务，并且正在关注本文档<a href="https://docs.confluent.io/5.3.0/installation/oper
这是我的kafka连接器属性
<pre><code>##
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor lic
我试图在Windows计算机上运行.net融合的Kafka客户端。 ConsumerBuilder无法构建使用者并抛出此错误：
<pre><c
在为kafka-connect：5.5.0构建自定义docker映像时遇到此错误。<br/>
我确实在必要的位置有“ apt-get更新”。有
我在ubuntu 18.04上运行了VM。
在此我安装：
<ul>
<li> python3.7
</li>
<li> confluent-kafka
运行python脚本
我想对Confluent的Git存储库<code>Dockerfile</code>进行一些修改，使其在我的Confluent Connect页面中具有mongoDB和Sno
我可以使用<code>kafka-avro-console-consumer</code>通过以下命令正确使用消息
<pre><code>./kafka-avro-console-consumer
如果我需要将同一主题中的相同数据复制到具有不同IP的多个数据库中，是否需要创建多个接收器连接器
我想描述一个主题的配置。我使用confluent-kafka-python librairie（版本1.5.0）开发了一个脚本，而我的python版
我已经在我的私人Windows 10计算机上使用模式化Docker构建了Confluent平台。现在，我想使用Confluent CLI，为此
想了解Apache Kafka 2.5.0版是否与代理服务器上安装的RHEL 8操作系统兼容。
有人知道如何从ProduceAync解析Kafka <code>DeliveryResult</code>。 dr.Value看起来具有Schema和内容，但是它不是JSON
我注意到我的Confluent平台启动并立即退出服务。 <code>docker-compose up -d</code>的第二次运行建立了环境。从
