clusterResource Listeners

概述 本文主要是分享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服务器的地址，配置多台的服务 用,分割， 其中一个宕机，生产者...