kafka_2.12-1.1.0 生产与消费java实现示例--参数设置备注：1）bootstrap.servers --设置生产者需要连接的kafka地址2）acks --回令类型3）retries --重试次数4）batch.size --批量提交大小5）linger.ms --提交延迟等待时间（等待时间内可以追加提交）6）buffer.memory --缓存大小7）key.serializer|value.serializer --序列化方法需要注意的点:1、本机是否能telnet xx.xx.x.xx 通？ 如果telnet端口不通，则需要关闭防火墙2、acks回令。如果必须等待回令，那么设置acks为all；否则，设置为-1；等待回令会有性能损耗。3、生产者在发送消息的过程中，会自己默认批量提交。所以，如果单条指令的发送请求，记得发送完后flush才能生效。4、SimplePartitioner2.java为kafaka分区，可选项。