概述 本文主要是分享Kafka初始化生产者的大体过程 初始化过程中会新建很多对象,本文暂先分享部分对象 1.分区器---Partitioner partitioner 2.重试时间---long retryBackoffMs 3.序列化器---Serializer<K> keySerializer,Serializer<V> valueSerializer 4.拦截器---List<ProducerInterceptor<K, V>> interceptorList 5.累加器---RecordAccumulator accumulator 6.元数据---ProducerMetadata metadata 7.创建sender线程---Sender sender 生产者初始化代码示例: 后续分享这些配置会被用到什么地方,生成上述哪些对象 // 这是构建kafka生产者的[示例代码] // 设置属性 Properties properties = new Properties(); // 指定连接的kafka服务器的地址,配置多台的服务 用,分割, 其中一个宕机,生产者...