怎么在Java中利用卡夫卡发送消息 - 行业资讯 - 肥雀云

　　介绍

这期内容当中小编将会给大家带来有关怎么在Java中利用卡夫卡发送消息,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

1。maven依赖包

& lt; dependency>, 　　,& lt; groupId> org.apache.kafka, 　　,& lt; artifactId> kafka-clients, 　　,& lt; version> 0.9.0.1, 　　& lt;/dependency>

2。生产者代码

package com.lnho.example.kafka;,, 　　import org.apache.kafka.clients.producer.KafkaProducer, 　　import org.apache.kafka.clients.producer.Producer, 　　import org.apache.kafka.clients.producer.ProducerRecord;,,, 　　import java.util.Properties;,,, 　　{public class KafkaProducerExample 　　,public static void main (String [], args), {, 　　Properties 才能;props =, new 属性(),, 　　props.put才能(“bootstrap.servers",,“师父:9092“),, 　　props.put才能(“acks",,“all"),, 　　props.put才能(“retries",, 0),, 　　props.put才能16384年“batch.size",,,, 　　props.put才能(“linger.ms",, 1),, 　　props.put才能(“buffer.memory",, 33554432),, 　　props.put才能(“key.serializer",,“org.apache.kafka.common.serialization.StringSerializer"),, 　　props.put才能(“value.serializer",,“org.apache.kafka.common.serialization.StringSerializer"),,,, 　　Producer<才能,字符串,String>, producer =, new KafkaProducer<祝辞(道具),, 　　,,(int 小姐:=,0;,小姐:& lt;, 100;,我+ +), 　　,,producer.send (new ProducerRecord<祝辞(“topic1",, Integer.toString(我),Integer.toString(我))),,,, 　　producer.close才能(),, 　　}大敌; 　　}

3。消费者代码

package com.lnho.example.kafka;,,, 　　import org.apache.kafka.clients.consumer.ConsumerRecord, 　　import org.apache.kafka.clients.consumer.ConsumerRecords, 　　import org.apache.kafka.clients.consumer.KafkaConsumer, 　　import java.util.Arrays, 　　import java.util.Properties;,,, 　　{public class KafkaConsumerExample 　　,public static void main (String [], args), {, 　　Properties 才能;props =, new 属性(),, 　　props.put才能(“bootstrap.servers",,“师父:9092“),, 　　props.put才能(“group.id",,“test"),, 　　props.put才能(“enable.auto.commit",,“true"),, 　　props.put才能(“auto.commit.interval.ms",,“1000“),, 　　props.put才能(“session.timeout.ms",,“30000“),, 　　props.put才能(“key.deserializer",,“org.apache.kafka.common.serialization.StringDeserializer"),, 　　props.put才能(“value.deserializer",,“org.apache.kafka.common.serialization.StringDeserializer"),, 　　KafkaConsumer<才能,字符串,String>, consumer =, new KafkaConsumer<祝辞(道具),, 　　consumer.subscribe才能(arrays . aslist (“topic1")),, 　　while 才能;(真实),{, 　　,,ConsumerRecords<字符串,String>, records =, consumer.poll (100),, 　　,,for (字符串,ConsumerRecord, record :,记录), 　　,,,System.out.printf (“offset =, % d, key =, % s,, value =, % s \ n",, record.offset (),, record.key (),, record.value ()),, 　　,,}, 　　}大敌; 　　}

上述就是小编为大家分享的怎么在Java中利用卡夫卡发送消息了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注行业资讯频道。