Kafka: Library: Sarama

 20th May 2022 at 4:20pm

这 两篇 帖子 提到了 Sarama 在 consumer rebalance 时的不稳定性。出于稳定性考虑，confluent-kafka-go 应该是更好的选择；但是它使用了 CGO，使得编译比较慢。

配置

Samara 提供了详细的 Config 结构。编程实现时要设置好这个结构，来实现稳定可靠的读取和写入。

Consumer

消费消息有两套 API：

错误处理

Kafka: Library: Sarama: Error Handling Kafka: Library: Sarama: Pitfalls

TOC

  1. Kafka: Library: Sarama: Config
  2. Kafka: Library: Sarama: Consumer API
  3. Kafka: Library: Sarama: Consumer Group API
  4. Kafka: Library: Sarama: Error Handling
  5. Kafka: Library: Sarama: Fetch Messages
  6. Kafka: Library: Sarama: Pitfalls