消费者通过
subscribe()
和
assign()
两种方式订阅主题
subscribe()
使用
subscribe()
可以订阅一个或多个主题，对于这个方法而言，可以以集合的方式订阅多个主题，也可以以正则表达式的形式订阅特定模式的主题。
subscribe 的几个重载方法如下：
public void subscribe(Collection<String> topics)
public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
public void subscribe(Pattern pattern)
public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
对于消费者以集合的方式订阅主题，如果前后两次订阅了不同的主题，以最后一次的订阅为准，前面的订阅都会失效，如：
consumer.subscribe(Arrays.asList("topic1"));
consumer.subscribe(Arrays.asList("topic2"));
上述的示例，最终订阅的是 topic2，由此可以看出来 topic1 订阅失效了。
如果以正则表达式的方式订阅主题，在之后的过程中，如果新创建了新的主题，并且主题的名称与正则表达式相匹配，那么这个消费者就可以消费到这个新添加的主题中的消息。
示例如下：
consumer.subscri
@springboot集成的kafka消费遇到的问题
这是一篇寻求帮助的博客，也是我第一次写，不太规范什么的还请不要在意。直接步入正题吧，我在用springboot
集成的kafka进行解析消费的时候遇到的问题。在我解析第一个topic的时候是可以正确解析并消费的；然后我解析第二
个topic也是可以正确消费的。但是当我想要让他们一起消费的时候就出现了这样的错误。（过后展...
文章目录1、环境准备2、生产者普通消息同步消息异步消息3、
消费者
（1）基础示例（2）顺序消费（2）消费模式a.集群模式b.广播模式（3）重复消费4、accessKey和secretKey
1、环境准备
pom引入依赖
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter&l
pom.xml：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apac
面试职位：java后端开发工程师。
在面试前三面真的有点急促，一周内就面完了三次面试，接着就开始无尽的等待，整整等了三周左右，终于完成了三面和HR面。整个过程还是比较曲折的，技术面试还是挺考察技术深度的。现在已拿到offer。面试问题如下：
蚂蚁金服一面：
先自我介绍，讲讲自己基础掌握情况，以及项目经历平时会用到哪些数据结构？
链表和数组的优缺点？
解决hash冲突的方法有哪些？
讲讲自己对HashMap的理解，以及和Weakhashmap的区别？
你刚才讲的是JDK1.7版本的实现，知道JDK1.8做了.
