kafka流avro消费者无法检索ID 10007的Avro模式
我正在运行一个试图从Confluent Cloud消费AVRO记录的Kafka流消费者。我一直遇到错误：错误检索ID 100007的AVRO未知模式和未经授权；错误代码：401 。…
我可以让Kafka Connect服务作为独立服务吗
我在第一服务器中使用了Apache Kafka，在第二服务器中使用了Apache Zookeeper。 我想在其他服务器中拥有Kafka Connect服务。可以使用独立服务。我需要…
Kafka-Console-Consumer收到的图像经过正确处理，但Java程序已损坏。如何解决这个问题？
我试图将图像从一个Kafka制作人发送到另一个Kafka-Consumer。我已经为消费者编写了一个Java程序，并且当Kafka-Console-Consumer收到数据（图像转换为…
Kafka Mongo水槽连接器因端口8083而降级
我正在使用我提供的docker-compose.yml构建的kafka/mongo docker群集。 我有5个容器： -Kafka -Mongo：用户名：root Pass：root -kafka -connector -C…
Ha Strimzi Kafka-Bridge的文档？
我们正在考虑使用strimzi kafka-bridge（）作为http（s）网关，通往现有的kafka群集。 该文档提到了使用任意名称参与消费者组的消费者的创建。这些名…
KAFKA MSK-高fetch.max.wait.ms and fetch.min.bytes的配置出乎意料
我有一个在春季应用程序上运行的Kafka消费者。 我正在尝试使用 fetch.max.wait.ms 和 fetch.min.bytes 。 我希望消费者等到有15000000字节的消息或1分…
python confluent-kafka deserializationconsumer也没有阅读Kafka主题的消息，即使消息存在
我在Avro架构中有一个主题，我正在通过Python代码生成消息，并且效果很好。当我消耗CLI的消息时，我可以在没有错误的情况下成功食用它们。 当我试图通…
org.apache.zookeeper.keeperxception $ noauthexception：keeperErrorcode = noauth for /cuntumeer
我有三个服务器可以运行Zookeeper和Kafka簇。有一天，Kafka应用程序的一个没有打开9092端口，也没有重新启动。这是错误日志： [2022-06-30 11:50:42,4…
非法模式字符＆＃x27; t＆＃x27;当使用transforms.timestampconverter.format在kafka jdbc stink连接器中
我准备构建一个JDBC接收器连接器，以将KAFKA到PostgreSQL的一些数据编写。 我的源数据具有时间戳列，值将就像'2022-06-29T04：00：00z'。 kafka连接器…
为什么当kafka需要时，为什么不需要兔子登记室注册表？
如果Kafka需要，因为队列中可能会有很多消息。如果您不阅读兔子，兔子也会发生同样的情况。 如果您使用的是Arvo或Protobuf，则需要此注册表。因此，可…
连接到在Docker中运行的Kafka
我在本地计算机上设置了一个单个节点kafka docker容器，如汇合文档（步骤2-3）。 此外，我还暴露了Zookeeper的端口2181和Kafka的端口9092，以便我能够…
通过Debezium将SQL Server连接到KAFKA时是否有问题
我的生产数据库有问题。 在测试和生产中，在我们的MSSQL数据库中激活的CDC。但是，只要在测试数据库中存储新记录，我们就会在Kafka主题中收到捕获的记…
