黑马Kafka笔记代码.zip

黑马kafka笔记与代码，是b站最好的一个视频的笔记，还可以多多看看其他书。需要视频也在博客主页评论

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个文件信息