kafka原生api怎么动态创建消费线程

第一种

@KafkaListener(topicPattern = "xxx-topic.*")，如果有新的topic创建是能拉取消息消费的。

第二种

consumer.subscribe(Pattern.compile("xxx-topic.*"))，用这种如果新加topic是没有办法订阅动中途新建topic,只有重起服务才能消费

请问，用第二种原生api写消费者，怎么动态获取topic来创建消费线程