apache-kafka 相关问题

Apache Kafka是一个分布式流媒体平台，用于存储和处理高吞吐量数据流。

如何阻止“遥测客户端实例ID”从AAAAAAAAAAAAAAAAAAAAAAA更改为“登录Confluent-kafka-python消费者？

＃消费者1 | [thrd：ma ...

python kubernetes apache-kafka confluent-kafka-python

回答 1 投票 0

KAFKATEMPLATE.SEND（消息）正在尝试在“身份验证失败”上连接无限时间

java authentication apache-kafka

回答 2 投票 0

我们继续获得NotControllerException：主动控制器似乎是节点xx

我们正在由Strimzi操作员部署的Kubernetes运行Kafka群集。我们正在运行Strimziv。0.45.0和Kafka 3.9.0。我们不断收到此错误“ notControllerReRexception：活动

apache-kafka strimzi

回答 1 投票 0

<code>@KafkaListener(topics = "abcd-topic") public void processRecords(List<ConsumerRecord<String, Word>> consumerRecords) </code>

processRecords

spring-boot apache-kafka spring-kafka kafka-consumer-api

回答 0 投票 0

在停止flink工作时，卡夫卡的问题（at_least_once and aker_once）

我们正在使用Kafka和AT_LEAST_ONCE策略使用Apache Flink。出现以下问题：停止工作时，Flink会因尚未处理的消息而定，结果...

scala apache-kafka apache-flink flink-checkpoint

回答 1 投票 0

如何防止我的卡夫卡消费者消耗新消息

我面临的问题是，我希望重试消费者仅处理初始化时重演主题中已经在重试的消息中的消息，而忽略后来发布给该主题的任何新消息。这是为了防止一种场景，其中一条失败处理的消息被卡在无限的重新处理和重新处理中。

.net-core apache-kafka kafka-consumer-api kafka-topic confluent-kafka-dotnet

回答 0 投票 0

在Maven

java maven apache-kafka avro

回答 1 投票 0

如何使用SYBASE ASE数据库的Kafka Connect实现更改数据捕获（CDC）？我有一个要求，我必须将实时数据库更新流式传输到Kafka主题。因此，基本上，只要在数据库中添加，更新或删除某些内容时，我希望将该更新推入

是的，有人可以给我很好的文件吗？我在互联网上找不到任何东西。

apache-kafka sybase sap-ase debezium cdc

回答 2 投票 0

如何确保NEO4J交易更改被以单个KAFKA消息发送在Spring Boot应用程序中

spring-boot apache-kafka neo4j apache-kafka-connect change-data-capture

回答 0 投票 0

java.lang.illegalargumentException：要求失败：sasl.mechanism.inter.broker.proker.protocol必须包含在sasl.enabled.mechanisms

当我尝试使用Docker-Compose开始Kafka时，出现了错误： java.lang.IllegalArgumentException：要求失败：sasl.mechanism.inter.broker.protocol必须包含在sasl.enabled.mechani ...

docker apache-kafka docker-compose

回答 1 投票 0

卡夫卡（Kafka）确保实际处理所有消息后提交

这里的假设是，主题将使消费者群体具有多个具有多个分区的消费者。好吧，即使是一个分区和一个

c# apache-kafka

回答 1 投票 0

无法在\ windows \ kafka-server-start.bat中启动kafka

apache-kafka wmic

回答 0 投票 0

KAFKA消费者小组会议定时出现，没有小组协调员的成功响应：撤销任务和重新加入group

标题必须缩短一点。完整的错误消息更像是这样： X MS之后的Kafka消费者小组会议（在Join-State Steady中）未能成功回应

python apache-kafka

回答 1 投票 0

java.lang.noclassdeffounderror：org/apache/kafka/kafka/config/config/atravesskafkaconfig spring-kafka在3.3.2和kafka-client，kafka-client，kafka_2.13 on3.9.0

当我们运行Gradle扫描时，很少有Junit测试用例失败，以下错误 java.lang.noclassDeffoundError：org/apache/kafka/server/config/abfciptkafkaconfig 在提升后看到此错误...

java spring-boot apache-kafka

回答 1 投票 0

发现消费者到达Kafka主题结束的推荐方法是什么？

apache-kafka kafka-consumer-api

回答 0 投票 0

eRror：无法找到绑定文件节点node-librdkafka.node

node.js apache-kafka debian-jessie

回答 2 投票 0

关于Strimzi的Kafka Connection中的有关连接器插件版本的问题我正在使用Kafka Connect的功能来构建图像，我有一些问题。在所有示例中，我都使用了Strimzi操作员版本0.45.0。当我创建一个strimzi kafka connect ins ...

kubernetes apache-kafka apache-kafka-connect strimzi

回答 1 投票 0

我有一个带有Python烧瓶后端的NextJS前端。我有兴趣配置前端记录。我的开发团队将AWS用作我们的云提供商。我们正在寻找可扩展的解决方案...

logging apache-kafka next.js frontend

回答 1 投票 0

我正面临着Azure Databricks和Kafka集成的问题。我想设置一个ReadStream，但会收到以下错误：

azure apache-spark apache-kafka databricks confluent-platform

回答 0 投票 0

KafkaAsync消息生产者：重试不起作用

spring一起使用kafka。目前，我的重点只是生产者。在服务器端，我在本地计算机上运行了两个Kafka节点，Kafka版本：3.8.1.

java spring apache-kafka spring-kafka

回答 0 投票 0

apache-kafka 相关问题

最新问题