RdKafka 是一个高性能、跨平台、开源的消息队列库，由 C++ 实现。它既可以作为生产者，也可以作为消费者，支持多种可扩展的消息路由策略，并提供了丰富的配置选项和 API 接口。

在实际应用场景中，RdKafka 可以用来解决大规模数据处理、日志收集、事件推送等问题。相比于其他消息队列库，例如 Apache Kafka、RabbitMQ 等，RdKafka 的最大优势在于它的高吞吐量和低延迟。

RdKafka 支持通过消费者组的方式共享消息接收负载。消费者组是多个消费者实例共同处理相同的一批消息的逻辑概念，每个消费者实例只负责处理一部分消息。这种方式可以提高消息处理的并发度和容错性。

使用 RdKafka 创建消费者组十分简单，只需要在配置项中设置 group.id 参数即可：

注意，如果多个消费者实例的 group.id 参数相同，即它们属于同一个消费者组。

在某些情况下，消费者需要重新读取历史消息。RdKafka 提供了两种方式来支持消费者进行消息回溯：

从指定偏移量开始消费。 消费者可以通过设置 offset 参数来指定从哪个偏移量开始消费。例如，以下代码将创建一个新的消费者，从主题 test 的第 10 条消息开始消费：

从最早或最新的消息开始消费。 消费者可以通过设置 auto.offset.reset 参数来指定从哪里开始消费，可以选择 earliest 或 latest，分别表示从最早或最新的消息开始消费。例如，以下代码将创建一个新的消费者，从主题 test 的最新消息开始消费：

在 Kafka 中，一个主题可以被分成多个分区，每个分区存储的消息是有序的。RdKafka 支持根据业务需求自定义消息分区策略。

具体来说，RdKafka 提供了一个抽象类 RdKafka::PartitionerCb，通过继承该类并实现 partitioner_cb 方法来自定义分区策略。例如，以下代码将创建一个新的生产者，并使用 CustomPartitioner 自定义分区策略：

在某些情况下，消费者只对感兴趣的消息进行处理，而忽略其他消息。RdKafka 提供了两种机制来支持消息筛选：

主题过滤器。 消费者可以设置主题过滤器参数，只接收符合规则的消息。例如，以下代码将创建一个新的消费者，只接收主题名以 test- 开头的消息：

消息过滤器。 消费者可以实现 ConsumeCb 接口，并在 consume_cb 方法中对消息进行筛选。例如，以下代码将创建一个新的消费者，通过 CustomConsumeCb 对消息进行筛选：

下面是一个完整的 RdKafka 生产者和消费者实现，支持自定义分区和消息回溯。生产者从标准输入中读取用户输入的消息，然后发送给 Kafka 集群；消费者从指定偏移量开始消费指定主题的消息，并打印到标准输出中。