kafka消费者如何动态订阅或者退订(Java)?

林旺 发布于 2017/06/16 16:11
阅读 1K+
收藏 0

kafka.0.10消费者想在程序运行中,动态订阅或者退订topic,要怎么实现?

直接操作subscribe方法的话,报错

KafkaConsumer is not safe for multi-threaded access

请问如何操作呢?

加载中
返回顶部
顶部