基于Apache Kafka主题消息更新/删除DB中更新/删除记录的最佳方法
我有一个有关KAFKA主题的应用程序发布消息。我已经使用Confluent的雪同步将主题与雪花表同步，因此当我将消息发布到该主题时，它将插入表格中。 每次…
无法使用.NET连接到Kafka服务器
我无法从.NET连接到Kafka服务器。我们使用以下命令创建了.pem文件的TrustStore.jks文件 keytool -exportcert -alias $alias -keystore $keyStore -rfc…
无法解决Kubernetes服务的地址
我已经安装了kafka 单节点使用 confluent 。 kafka pod中存在错误： [WARN] 2022-04-26 14:29:47,008 [main-SendThread(zookeeper.confluent.svc.clus…
kerberos错误在汇合卡夫卡上进行身份验证
我一直在尝试了解Apache Beam，Confluent Kafka和与Python 3.8和Beam SDK 2.7的DataFlow集成的需求结果是构建管道（将在数据流上运行），该管道从Conf…
CP-KAFKA连接不加载Debezium mysql连接器
我有一个 cp-kafka-connect 运行的服务： connect: image: confluentinc/cp-kafka-connect ports: - "8083:8083" depends_on: - kafka environment: C…
Confluent平台7.1是否基于Kafka免费？开源？用于生产
我有USECASE开始使用Kafka，并正在寻找免费（生产）Kafka。 当Check Confluent 7.1平台看起来很合适，因为它具有Zookeeper / kafka / schema注册表 / …
java.lang.verifyError：使用org.springframework.kafka.support.serializer.jsondeserialializer（）时返回类型不良
我想在 https:// 上尝试同步 Kafka dzone.com/articles/synchronous-kafka-using-spring-request-reply-1 但是，当它加载时，我遇到了 java.lang.Veri…
使用Load Alancer复制从AWS Kafka到Contruent Kafka的Kafka数据
我有一个用例，用于将 Kafka 主题和数据从 AWS 中的一个 Kafka 集群复制到部署在 AWS 上的 Confluence Kafka。问题是，我在 AWS 中的 Kafka 部署在 VP…
重新平衡期间的 kafka 提交
场景： Kafka 版本 2.4.1。 Kafka 分区正在主动处理消息。 CPU 使用率较低，内存使用率一般，并且没有观察到限制。 使用 confluence 的 go 客户端版本…
Kafka 汇至 InfluxDB
我正在尝试使用 Confluence/Kafka 堆栈将数据从我的 kafka 主题获取到 InfluxDB 中。目前，主题中的消息的形式为{“tag1”：“123”，“tag2”：“456…
confluenceinc/cp-kafka docker log4j 警告
docker pull confluentinc/cp-kafka 我使用这段代码来拉取kafka图像。 然后，使用以下命令启动容器。 docker run --rm -d --name kafka-server -p 909…
不同端口上的 Confluence 连接不工作
我正在 Linux 计算机上使用 portainer 设置 Confluence-Stack。我的其他容器之一已经在使用端口 8083（默认的汇合连接端口） - 因此我将 docker-compo…
我们可以从融合的 kafka 主题中选择特定行的记录吗？
在我的本地 Confluence 平台中，我有 1 个名为“FOO_02”的主题，我已手动向其中插入一些记录，因此，我可以使用以下命令从头开始打印它： print 'FOO…
创建没有数据聚合的表
我刚刚开始使用 ksqlDB Confluence 功能，发现无法继续执行以下命令： CREATE TABLE AS SELECT A, B, C FROM [STREAM_A] [EMIT CHANGES]; 我想知道为…
