kafka-consumer

卡夫卡消费者 Kafka-consumer是kafka的大数据消息阅读器。 特征 使用Kafka的高级/低级API连续接收Kafka数据。 在故障过程中，我们只需在每个批次间隔的开始确定要消耗的偏移量范围是多少。 从Kakfa读取与偏移范围相对应的数据进行处理。这些偏移也可以通过zookeeper可靠地保存，并用于重新计算数据以从故障中恢复。 要求 JDK1.7或更高版本 Maven 3.2或更高版本 动物园管理员3.3 卡夫卡-0.8 建造 要构建项目，只需运行以下命令 mvn clean install 用法