如何映射汇合。＆＃x27;前缀变量适用于正确的Docker Envs？
假设我需要更改 confluent.security.event.logger.exporter.kafka.topic.replicas 或 confluent.metrics.reporter.reporter.topic.replicas 。 如何通…
汇合控制中心的故障：无法获得消费者的群集ID
我正在运行Confluent平台（版本6.1.1）。我部署以下组件：3个经纪人，3个ZK，架构注册表，3 Kafka Connect，KSQL和Confluent Control Center（CCC）。…
从Confluent Kafka模式注册表中检索特定主题/模式
我正在使用Confluent Kafka模式注册表，并定义了一些模式/主题。 几个示例： dev.delivery.kafka.delivery-reason-value dev.delivery.kafka.delivery…
kafka Connect Confluent S3水槽连接器：io.confluent.connect.avro.avroconverter无法找到
使用此kafka连接器： 我将其手动安装到我的kafka connect docker image的/opt/opt/kafka/plugins 。 我的目的是使用Kafka Connect将AVRO记录从Kafka主…
创建弹性水槽连接器时序列化错误
在创建弹性水槽连接器时，我遇到了以下错误。 CREATE SOURCE CONNECTOR `testconnector` WITH( "type.name"= '_doc', "input.data.format"= 'AVRO', "…
如何将生产的JSON密钥设置为MongoDB Atlas的文档_id
我正在构建一个数据管道，在那里我通过KAFKA将刮擦数据发送到MongoDB Atlas（全部在云中，而不是本地）。 我用我的Contruent Kafka配置初始化了一个生…
如何启用Confluent.Value.schema.CP-Helm-charts的验证
我正在使用掌舵使用 cp-helm-charts 我已经启用了Zookeeper，Zookeeper， Kafka，架构注册表和控制中心组件。在Control Center UI中，我能够创建一个…
重新连接如何在Kafka流中工作？
NOOB问题，但是当您在Kafka流中重新关注主题时会发生什么？ 例如，假设我想实现WordCount，类似于 htttps：htttps：// docs .confluent.io/4.1.1/stre…
跨两个不同的kafka连接群集的同一消费者组（S3接收器连接器）
我正在将Kafka连接器从ECS群集迁移到在Kubernetes上运行的新集群。我通过删除Postgres源连接器并在确切的复制插槽上重新创建它们，成功地迁移了Postgr…
kafka流：如何避免在完成之前抑制调度器注点器
我有一个Kafka流应用程序，需要将一些数据处理到 stateStore 每个 x 分钟。 我创建了一个接收数据的变压器并将其存储到 stateStore 中。变压器是通过 …
模式注册表问题 - Protobuf工会
我们目前正在研究一个POC，该POC涉及使用“ Oneof”将多个事件带入同一主题。但是，在发布给联盟Kafka主题时，我们似乎会得到一个序列化例外。 我们正…
使用节点npm ksqldb-client抛出超时错误执行ksql查询
嗨，我正在尝试使用NPM软件包KSQLDB-CLIENT软件包执行KSQL查询，它会引发超时错误。我也附上了代码，请让我知道那里的任何问题。 当点 get url下面的…
KAFKA MM1.0 vs KAFKA MM2.0与汇合复制器与汇合群集链接
我知道Apache Kafka MM1和Apache Kafka MM2之间有什么区别。 不支持主动设置和抵消同步 KAFKA MM1不支持MM1中的一个问题和更多使用irrirormaker 2.0 a…
Confluent Kafka 101教程遵循，错误：get'https：//confluent.cloud：8090/security/security/1.0/authenticate＆quot;：dial tcp＆lt; ip＆gt;：8090：i/o timeout
我一直在关注Confluent的官方教程，如YouTube https://www.youtube.com /watch？v = oi7vas9kss4 当涉及汇合CLI的部分（大致启动5'28''）时，Confluen…
