使用idea编写代码作为生产者，Kafka接收其发来的信息【小案例】(一)

对于这个小案例，简单来个图示，

友情补充pom

    <dependencies><dependency><groupId>org.apache.spark</groupId><artifactId>spark-core_2.11</artifactId><version>2.3.1</version></dependency><dependency><groupId>org.apache.spark</groupId><artifactId>spark-hive_2.11</artifactId><version>2.3.1</version></dependency><dependency><groupId>org.apache.spark</groupId><artifactId>spark-sql_2.11</artifactId><version>2.3.1</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version></dependency><!-- 向kafka 生产数据需要包 --><dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>0.10.0.0</version></dependency></dependencies>

代码

package com.kafkaimport java.util.Propertiesimport org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}object KafkaDemo {def main(args: Array[String]): Unit = {val props = new Properties()props.setProperty("bootstrap.servers","henu2:9092")props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");val kp = new KafkaProducer[String,String](props)println("++++")kp.send(new ProducerRecord[String,String]("george","georgedage"))kp.close()}
}

运行前，在linux上进行kafka的消费者命令。

kafka-console-consumer.sh --bootstrap-server henu2:9092 --from-beginning --topic george

然后运行idea的代码，注意你的主题名称要一致。

运行结果：

使用idea编写代码作为生产者，Kafka接收其发来的信息【小案例】(一)相关推荐

用idea编写代码作为生产者，Kafka接收其【持续】发来的广告日志信息【小案例】(二)
接我们上一篇使用idea编写代码作为生产者,Kafka接收其发来的信息[小案例](一) https://georgedage.blog.csdn.net/article/details/1035034 ...
使用idea编写消费者，接收生产者的持续日志输出【小案例】（三）
在用idea编写代码作为生产者,Kafka接收其[持续]发来的广告日志信息[小案例](二) https://georgedage.blog.csdn.net/article/details/10 ...
java生产者消费者代码_Java实现Kafka生产者消费者代码实例
Kafka的结构与RabbitMQ类似,消息生产者向Kafka服务器发送消息,Kafka接收消息后,再投递给消费者. 生产者的消费会被发送到Topic中,Topic中保存着各类数据,每一条数据都使用键 ...
键盘录入两个数a,b并接收，编写代码实现a,b交换，打印结果
import java.util.Scanner;public class HomeWork {public static void main(String[] args) {//1.键盘录入小明左右 ...
使用idea编写SparkStreaming消费kafka中的数据，并对数据进行某一指标的处理【小案例】（五）
接使用idea编写SparkStreaming消费kafka中的数据[小案例](四) https://georgedage.blog.csdn.net/article/details/1035 ...
使用idea编写SparkStreaming消费kafka中的数据【小案例】（四）
继续接使用idea编写消费者,接收生产者的持续日志输出[小案例](三) https://georgedage.blog.csdn.net/article/details/103506165 ...
编写一个静态方法lg()，接收一个整型参数N，返回不大于log2N（以2为底）的最大整数。不要使用Math库。
题目: 编写一个静态方法lg(),接收一个整型参数N,返回不大于log2N的最大整数.不要使用Math库. 代码: public class Node {public static void main ...
使用java数据结构编写代码
使用java数据结构编写代码数组数据结构数组的初始化 public static void main(String[] args) {int[] arrays = new int[5]; // 定 ...
python中如何编写代码输入多个数据并把它们放在一个列表中去_编写高质量Python代码的59个有效方法，你用过几个...
欢迎点击右上角关注小编,除了分享技术文章之外还有很多福利,私信学习资料可以领取包括不限于Python实战演练.PDF电子文档.面试集锦.学习资料等. 这个周末断断续续的阅读完了<Effectiv ...

使用idea编写代码作为生产者，Kafka接收其发来的信息【小案例】(一)

对于这个小案例，简单来个图示，

友情补充pom

代码

运行前，在linux上进行kafka的消费者命令。

然后运行idea的代码，注意你的主题名称要一致。

运行结果：

使用idea编写代码作为生产者，Kafka接收其发来的信息【小案例】(一)相关推荐

最新文章

热门文章