手动管理kafka的偏移量
package com.cartravel.kafkaimport java.lang.Longimport kafka.utils.{ZKGroupTopicDirs, ZkUtils}import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord, KafkaConsumer, NoOffsetForPartitionException}import org.apache.kafka.common.TopicP
