java代码调用kafka API实现消费数据

订阅主题 轮训消费数据 同步提交当前偏移量（后面的任务会阻塞） 异步提交当前偏移量 异步回调方式提交当前偏移量 同步和异步组合提交当前偏移量 提交特定的偏移量（在处理数据的总监提交偏移量） 原子性提交当前偏移量 调用消费者api获取数据      订阅主题，可以用正则表达式匹配，下面指定以test开始的主题都会监听。          轮训消费数据（一旦消费者订阅了主题，轮训会处理所有的细节，包括

>>阅读原文<<