英文: Kafka consumers in consumer group reading from different Kafka cluster 问题 我们有两个Kafka集群,分别是A和B。我们...
如何限制Kafka消费者拉取的数据量(以字节为单位)?
英文: How to limit kafka consumer poll result in bytes? 问题 我的设置有三个Kafka代理和十几个主题,每个主题有15个分区。 Java应用程序启动...
从SvelteKit访问Kubernetes中的Kafka
英文: Accessing Kafka in Kubernetes from SvelteKit 问题 我正在构建一个具有Kafka支持的SvelteKit应用程序。我已经创建了一个kafka.js文...
消费者组在Kafka中的需求是什么?
英文: What is the need of consumer group in kafka? 问题 我不理解Kafka中消费者组的实际用途。在消费者组中,一个分区只能被一个消费者读取,因此一个主题...
Kafka Streams库 v1.1.0 是否与Kafka集群 v2.8.1 向前兼容?
英文: Is Kafka Streams library v1.1.0 forward compatible with Kafka cluster v2.8.1? 问题 I'm running a K...
如何在运行时更改主题的偏移量?
英文: How to change offset of a topic during runtime? 问题 我有一个为 Kafka 主题提供消息的生产者,并且还有另一个服务从主题中读取这些消息。 我...
sarama.ConsumePartition实例是共享默认组还是使用不同的组?
英文: sarama.ConsumePartition instances is sharing default group or using different group? 问题 当我在不同的进程...
如何使用Shopify/sarama Golang库在Kafka中为主题添加消费者组?
英文: How to add consumerGroup for a topic in kafka using Shopify/sarama golang library? 问题 在sarama库中,...
Confluent Go客户端 – 如何在集群上创建一个主题?
英文: Confluent go client - How to create a topic on a cluster? 问题 我们正在编写集成测试用例,使用confluent kafka prod...
Kafka的偏移量即使在未达到确认(Ack)时也会增加。
英文: Kafka offset increments even without reaching Ack 问题 我有一个消费者,它消费一条消息,执行一些繁重的任务,然后进行确认操作。 @KafkaL...
6