我们可以在Apache Kafka中将KStream转换为全局KTable吗？
我正尝试在Scala中制作kafka流。我想知道是否有可能...
融合BigQuerySinkConnector架构注册表错误
我尝试使用Confluent BigQuerySinkConnector创建从K...
融合BigQuerySinkConnector JSON转换器错误
我尝试使用有关Kafka主题的JSON数据创建到BigQuery的...
一天中到达Kafka主题的邮件数
是否有办法获取一天中通过Kafka主题到达的邮件数量？...
消息的键和值的不同模式类型
我想知道是否允许使用JSON密钥架构和AVRO值架构生成...
如何使用Kafka Confluent C＃客户端发送原始Json？
我有一个消费者应用程序，它期望JSON像这样：<co...
无法将IIDR CDC连接到kafka
当尝试通过Zookeeper将kafka的IIDR复制引擎连接到ka...
Kafka Avro Deserializer无法将Kafka消息反序列化为特定的Avro记录
我正在尝试将kafka中的Avro消息反序列化为从Avro Sc...
融合的Kafka连接器抛出“找不到适用于jdbc：postgresql的驱动程序”
我正在与3个kafka代理一起进行多节点Confluent kafk...
无法将工件io.confluent：kafka-connect-storage-common-parent：pom：6.0.0-SNAPSHOT从/转移到confluent$ {confluent.maven.repo}
我第一次尝试连接Kafka，我想将SAP S / 4 HANA连接到...
无法从本地计算机生成和使用kafka消息到ubuntu VM
我正在尝试从本地计算机向Ubuntu vm生成kafka消息。...
confluent-kafka python库不适用于ubutu14和python3
我正在使用“ confluent-kafka == 1.0.1”。当我使用...
必须指定Avro刻度，并且必须是数字s3连接器错误
我有数据从集群上的S3融合连接器同步到S3。我在其中...
怎样在KSQLDB中实现LAG之类的实现？
我最近开始使用ksql，想检查是否有人可以帮助我进行...