一. KafkaConsumer订阅topic数据的方式可以分为两种
1. 通过subscribe方法订阅，api接口如下：
1.1 public void subscribe(Collection topics)；
topics：想订阅相关topic集合
1.2 public void subscribe(Collection topics, ConsumerRebalanceListener listener)
topics：想订阅相关topic集合
listener：当相同group.id下有多个consumer时，会触发topic partition的重新分配，此参数就是重新分配时的回调监听器
举个例子：
例如test topic有两个partition，partition-0和partition-1
当group.id为test_group的consumer消费test topic的数据时，当只有一个consumer时，这个consumer负责消费partition-0和partition-1的数据。
如果此时再有一个group.id为test_group的consumer订阅test topic的数据时，就会触发consumer组的再平衡处理，每一个consumer分别负责消费一个partition的数据。
再平衡重新分配是如何实现的，这个比较复杂，会在后续的文章中通过源码，详细介绍
1.3 public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
pattern：想订阅相关topic的正则表达式
listener：当相同group.id下有多个consumer时，会触发topic partition的重新分配，此参数就是重新分配时的回调监听器
2. 通过assign方法订阅，api接口如下：
2.1 public void assign(Collection partitions)
partitions：想订阅相关topic的TopicPartition集合
此方法相当于是人为的控制我们想要订阅哪些topic的哪些partition
举个例子：
例如test topic有两个partition，partition-0和partition-1，可以通过下面的方式订阅
TopicPartition tp0 =new TopicPartition("test", 0);
TopicPartition tp1 =new TopicPartition("test", 1);
consumer.assign(Arrays.asList(tp0, tp1));
二 总结
通过上面对KafkaConsumer相关api的详细说明，我们可以得知，这两种方式的区别如下：
当相同group.id下有多个消费者时，subscribe相关api方法会自动触发消费者消费哪些topic partition的再平衡，
相反以assign相关api订阅则不会触发再平衡。
