KafkaProducer

KafkaProducer精品文章

• 

  搭建 kafka 运行环境

  ...* * Create by fengtang * 2015/10/8 0008 * KafkaDemo_01 */ public class KafkaProducer { private final Producer producer; public final static String TOPIC = TEST-TOPIC; private KafkaP...

  J4ck_Chan 2019-08-14 12:43 评论0 收藏0
• 

  Kafka源码阅读日记——ProducerInterceptor

  ...均来自https://github.com/apache/kafka Kafka Producer简单使用示例 KafkaProducer用于将事件从客户端应用发送至Kafka集群。Producer本身是线程安全的，并且多个线程共享单个实例时也会有性能上的提升。以下示例来自org.apache.kafka.clients.producer.K...

  Genng 2019-08-15 14:39 评论0 收藏0
• 

  Kafka参数调优实战，看这篇文章就够了！【石杉的架构笔记】

  ...ks, 1); props.put(retries, 10); props.put(retry.backoff.ms, 500); KafkaProducer producer = new KafkaProducer(props); 3、内存缓冲的大小首先我们看看buffer.memory这个参数是什么意思？Kafka的客户端发送数据到服务器，一般都是要经过缓冲的，也...

  cloud 2019-05-23 17:28 评论0 收藏0
• 

  《从0到1学习Flink》—— 如何自定义 Data Sink ？

  ...com.zhisheng.flink.model.Student; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerRecord; import java.util.HashMap; import java.util.Map; i...

  NikoManiac 2019-08-16 13:40 评论0 收藏0