比较核心的配置：metadata.broker.list、request.required.acks、producer.type、serializer.class
消费者获取消息元信息(topics, partitions and replicas)的地址,配置格式是：host1:port1,host2:port2，也可以在外面设置一个vip
metadata.broker.list
消息的确认模式
0：不保证消息的到达确认，只管发送，低延迟但是会出现消息的丢失，在某个server失败的情况下，有点像TCP
1：发送消息，并会等待leader 收到确认后，一定的可靠性
-1：发送消息，等待leader收到确认，并进行复制操作后，才返回，最高的可靠性
request.required.acks =0
消息发送的最长等待时间
request.timeout.ms =10000
socket的缓存大小
send.buffer.bytes=100*1024
key的序列化方式，若是没有设置，同serializer.class
key.serializer.class
分区的策略，默认是取模
partitioner.class=kafka.producer.DefaultPartitioner
消息的压缩模式，默认是none，可以有gzip和snappy
compression.codec = none
可以针对默写特定的topic进行压缩
compressed.topics=null
消息发送失败后的重试次数
message.send.max.retries =3
每次失败后的间隔时间
retry.backoff.ms =100
生产者定时更新topic元信息的时间间隔 ，若是设置为0，那么会在每个消息发送后都去更新数据
topic.metadata.refresh.interval.ms =600*1000
用户随意指定，但是不能重复，主要用于跟踪记录消息
client.id=""
------------------------------------------- 消息模式 相关 -------------------------------------------
生产者的类型 async:异步执行消息的发送 sync：同步执行消息的发送
producer.type=sync
异步模式下，那么就会在设置的时间缓存消息，并一次性发送
queue.buffering.max.ms =5000
异步的模式下 最长等待的消息数
queue.buffering.max.messages =10000
异步模式下，进入队列的等待时间 若是设置为0，那么要么进入队列，要么直接抛弃
queue.enqueue.timeout.ms = -1
异步模式下，每次发送的最大消息数，前提是触发了queue.buffering.max.messages或是queue.buffering.max.ms的限制
batch.num.messages=200
消息体的系列化处理类 ，转化为字节流进行传输
serializer.class= kafka.serializer.DefaultEncoder
