1 数据结构 消费者的消费状态是保存在SubscriptionState类中的,而SubscriptionState有个重要的属性那就是assignment保存了消费者消费的partition及其partition的状态 public class SubscriptionState { /* the pattern user has requested */ private Pattern subscribedPattern; /* the list of topics the user has
IMPLEMENTATION 1. API Design Producer APIs Producer API封装了底层两个Producer: kafka.producer.SyncProducer kafka.producer.async.AsyncProducer class Producer { /* Sends the data, partitioned by key to the topic using either the */ /* synchronous or the async