kafka工作原理（新人向，代码向）
以上来自：链接
怎么向kafka send消息呢？
如何向kafka send消息
可以看出，由producer对象中的send方法中用ProducerRecord封装了个由topic,key,value组成的消息。
producer:
原来就有的Producer接口
其中producer对象是由原来就有的Producer接口生成的。
send:
Producer接口中send方法介绍
消息的组成：topic,key和value
topic:
send时的目标主题。
key:
用atomicLong实现若空时自增的键。
value:
将value对象转化为Json字符串send到kafka
如何转化？
JSON.toJSONString则是将对象转化为Json字符串。
如何向kafka poll消息呢？
如何向kafka poll消息呢
consumer:与producer同理，只不过是消费消息罢了。
Duration.of:
大体意思是一段时间，比如这里10000millis，意思是10秒
duration.of含义
ConsumerRecords records =consumer.poll(Duration.of(10000, ChronoUnit.MILLIS));
在10秒内poll拿到的放进ConsumerRecord接口生成的records中，再把所有拿到的value放入result这个Arraylist中。（这部分与send部分类似，不详细写了）
commitAsync():
commitAsync详解
鄙人的拙劣翻译如下：
背景介绍：
要以文件存放消费的消息时，为了方便查找，对于过大的文件分成许多个小文件，并由offset来给这些小文件打标签（和数组的offset一个意思）。这个过程叫平均/重组(rebalance)。
我的翻译：
在最后一次从指定的主题分区中poll时，会拿到各个offset。
这个拿offset的行为只在kafka用。在最开始拿消息或重组之后，这个行为才会用这个api。所以，你想用这个api给不是kafka上的消息拿offset是不可能的。
这是个异步的过程，任何时候都不会被打断。遇到任何报错都会扔给callback（如果提供的话）或者被丢弃。
在多个调用这个api时，会根据调用先后来给offset。相应的callback也会以相同顺序给出。拿offset这个操作一定会在commitSync()返回前做完。
参数：callback——为了说明这个commitAsync操作完成了。
也就是说，这句话是设定怎么设置offset用的。
