package?com.heima.kafka;

import?org.apache.kafka.common.serialization.StringDeserializer;

import?java.util.Properties;

/**
?*?@Author?dayuan
?*?@Date?2019/7/11?14:46
?*/
public?class?ConsumerClientConfig?extends?KafkaContext?{

????public?static?Properties?initConfig（）?{
????????Properties?props?=?new?Properties（）;
????????//?key發序列化器
????????props.put（org.apache.kafka.clients.consumer.ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG?StringDeserializer.class.getName（））;
????????//?value反序列化器
????????props.put（org.apache.kafka.clients.consumer.ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG?StringDeserializer.class.getName（））;
????????//?Kafka集群地址列表
????????props.put（org.apache.kafka.clients.consumer.ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG?brokerList）;
????????//?消費組
????????props.put（org.apache.kafka.clients.consumer.ConsumerConfig.GROUP_ID_CONFIG?groupId）;
????????//?Kafka消費者找不到消費的位移時，從什么位置開始消費，默認：latest?末尾開始消費???earliest：從頭開始
????????//?props.put（org.apache.kafka.clients.consumer.ConsumerConfig.AUTO_OFFSET_RESET_CONFIG?“latest“）;
????????//?是否啟用自動位移提交
????????props.put（org.apache.kafka.clients.consumer.ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG?true）;
????????return?props;
????}

}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件??????217877??2019-08-30?18:00??Kafka.xmind
?????文件?????7480423??2019-10-14?16:53??Kafka課程講義.pdf
?????目錄???????????0??2019-10-15?15:49??代碼\
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\
?????文件?????????326??2019-06-20?16:38??代碼\Kafka_Learn\.gitignore
?????文件?????????513??2019-06-26?16:00??代碼\Kafka_Learn\.git\COMMIT_EDITMSG
?????文件?????????331??2019-06-20?16:38??代碼\Kafka_Learn\.git\config
?????文件??????????73??2019-06-20?16:37??代碼\Kafka_Learn\.git\description
?????文件??????????23??2019-06-20?16:38??代碼\Kafka_Learn\.git\HEAD
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\hooks\
?????文件?????????478??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\applypatch-msg.sample
?????文件?????????896??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\commit-msg.sample
?????文件????????3327??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\fsmonitor-watchman.sample
?????文件?????????189??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\post-update.sample
?????文件?????????424??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\pre-applypatch.sample
?????文件????????1638??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\pre-commit.sample
?????文件????????1348??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\pre-push.sample
?????文件????????4898??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\pre-rebase.sample
?????文件?????????544??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\pre-receive.sample
?????文件????????1492??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\prepare-commit-msg.sample
?????文件????????3610??2019-06-20?16:37??代碼\Kafka_Learn\.git\hooks\update.sample
?????文件????????5829??2019-08-30?14:46??代碼\Kafka_Learn\.git\index
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\info\
?????文件?????????240??2019-06-20?16:37??代碼\Kafka_Learn\.git\info\exclude
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\logs\
?????文件?????????178??2019-06-20?16:38??代碼\Kafka_Learn\.git\logs\HEAD
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\logs\refs\
?????目錄???????????0??2019-10-15?15:49??代碼\Kafka_Learn\.git\logs\refs\heads\
?????文件?????????149??2019-06-20?16:54??代碼\Kafka_Learn\.git\logs\refs\heads\all
?????文件?????????178??2019-06-20?16:38??代碼\Kafka_Learn\.git\logs\refs\heads\master
............此處省略657個文件信息