apache-kafka

英文: gomock missing call(s) 问题 我正在尝试使用gomock来模拟下面的方法： func (w *writer) Publish(vacancies []model.Vaca...

英文: security.protocol error when setting up basic Kafka consumer and producer in Go? 问题 我正在尝试在Go中设置一...

英文: Golang delete all records from a topic in Kafka 问题 嗨，我正在使用Go和Kafka编写一个服务，并且需要实现一个删除所有记录的端点，该端点将从...

英文: Confluent go client - How to create a topic on a cluster? 问题 我们正在编写集成测试用例，使用confluent kafka prod...

英文: Kafka offset resets sometimes after consumer restart 问题 我有一个具有4个分区和4个具有相同消费者组ID的消费者的Kafka主题。 所有消...

英文: Kafka consumers picking up the same message again 问题 我有一个包含30个实例的golang服务。有一个包含3个分区的主题，一个单一的消费者组...

英文: How to apply an SMT to a single topic in Kafka connect? 问题 我想对单个主题应用一组单一消息转换（SMT，Single Message ...

英文: Spring Cloud Stream - Give Serdes to Individual Consumers/Producers 问题 我正在尝试在每个消费者上单独放置Serdes，而不...

英文: Spring Kafka cannot find Kafka Properties Bean 问题 我正在尝试在我的项目中使用 Spring Kafka，其中 Spring Boot 版本为 ...

英文: Send message in specific partition of Topic 问题 以下是您要翻译的内容： 生产者是否有办法将消息发送到代理中主题的特定分区？ 目前，我可以发送具有2...