Kafka API实战
2024-09-01 08:53:07
第4章 KafkaAPI实战
1）启动zk和kafka集群，在kafka集群中打开一个消费者
[hadoop102 kafka]$ bin/kafka-console-consumer.sh \ --zookeeper hadoop01:2181 --topic first
2）导入pom依赖
<dependencies>
<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.2.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.12</artifactId>
<version>2.2.1</version>
</dependency> </dependencies>
4.2 Kafka生产者Java API
4.2.1 创建生产者（过时的API）
最新文章
- USB
- poj2533 LIS
- [BZOJ 1483][HNOI 2009]梦幻补丁（有序表启发式合并）
- 什么是cookie
- javascript 手机号抽奖
- centos6安装vncserver实现图形化访问
- QT https post请求（QNetworkRequest要设置SSL证书，而SSL证书认证有三种，实测成功）
- 将时间显示为“刚刚”“n分钟/小时前”等
- 使用MVC4，Ninject，EF，Moq，构建一个真实的应用电子商务SportsStore
- CodeForces 710B Optimal Point on a Line
- Python 函数简介之一
- Rabbitmq集群安装配置
- StringBuffer的替换和反转和截取功能
- iOS UICollectionView(转三)
- Arrays.asList 为什么不能 add 或者 remove 而 ArrayList 可以
- 软件工程(GZSD2015) 第二次作业文档模板
- 吴恩达Machine Learning 第一周课堂笔记
- PAT基础6-11
- JavaScript之正方教务系统自动化教评[插件-转载]
- Qt封装百度人脸识别+图像识别