英文: kafka commit during rebalancing 问题 场景： Kafka版本为2.4.1。 Kafka分区正在主动处理消息。 CPU使用率较低，内存使用率中等，没有观察到限流。...
85评论go
kubernetes
Kafka在重新平衡期间进行提交
85评论go
kubernetes
85评论go
kubernetes
将消息从Kafka发送到WebSocket。
英文: Send messages from kafka into websocket 问题 我使用gin-framework在golang中创建了一个Web服务。在这个项目中，我还消费了来自特定主题...
97评论apache-kafka
go
如何在没有生产者的情况下创建 Kafka 消息？
英文: How to create a kafka message without producer? 问题 我想创建一个基本的测试用例，而不需要为测试创建生产者、消费者和Kafka实例。我在创建基本...
73评论apache-kafka
go
ksqldb – 拉取查询只有一个传递，多个应用程序实例
英文: ksqldb - exactly one delivery for pull query, multiple app instances 问题 我正在尝试在ksqldb之上构建一个应用程序。 ...
107评论apache-kafka
go
如何使用Benthos从Kafka读取和解码AVRO消息以及它们的关联Kafka键？
英文: How can I read and decode AVRO messages from Kafka along with their associated kafka key using B...
157评论apache-kafka
go
Apache Pulsar：从指定的消息 ID 读取/消费消息到结束消息 ID？
英文: Apache Pulsar: Read / Consume messages from an integer specified message id to an end message Id...
80评论apache-kafka
go
如何使用Shopify/sarama Golang库在Kafka中为主题添加消费者组？
英文: How to add consumerGroup for a topic in kafka using Shopify/sarama golang library? 问题 在sarama库中，...
92评论apache-kafka
go
Golang的Confluent Kafka消费者无法接收消息。
英文: golang confluent kafka consumer doesn't receive messages 问题 我正在尝试创建一个简单的生产者/消费者Kafka组合。由于生产者...
104评论apache-kafka
go
Kafka生产者终止，队列或传输中仍有1条消息（881字节）。
英文: Kafka Producer terminating with 1 message (881 bytes) still in queue or transit 问题 我对Kafka还不太熟悉，...
106评论apache-kafka
go
如何在Kafka go中编写单元测试
英文: How to write unit tests in Kafka go 问题 在golang中编写Kafka的单元测试的正确方法是什么？ 在Java中，对于Kafka流，我们有Kafka流测试...
80评论go
unit-testing
41