世界最新:配置完Kafka集群后 通过JavaAPI方式来操作
(资料图片仅供参考)
配置完Kafka集群后,下面通过Java API的方式来操作 需要导入的Jar包
kafka_2.10-0.8.1.1.jar log4j-1.2.15.jar metrics-core-2.2.0.jar scala-library-2.10.1.jar slf4j-api-1.7.2.jar
以上jar包均可从Kafka的发布包中找的到,在lib目录下面
生产者(Producers)
代码:
import java.util.*; import kafka.javaapi.producer.Producer;import kafka.producer.KeyedMessage;import kafka.producer.ProducerConfig;public class TestProducer { public static void main(String[] args) { long events = Long.parseLong(args[0]); Random rnd = new Random(); //在以下属性中定义了Producer如何找到集群,序列化消息等 Properties props = new Properties(); props.put("metadata.broker.list", "broker1:9092,broker2:9092 "); props.put("serializer.class", "kafka.serializer.StringEncoder"); props.put("partitioner.class", "example.producer.SimplePartitioner"); props.put("request.required.acks", "1"); ProducerConfig config = new ProducerConfig(props); //定义生产者对象,该类指定了两个参数的泛型,第一个参数表示分区键值的类型,第二参数表示消息类型 Producerproducer = new Producer(config); for (long nEvents = 0; nEvents < events; nEvents++) { long runtime = new Date().getTime(); String ip = “192.168.2.” + rnd.nextInt(255); String msg = runtime + “,www.example.com,” + ip; //发送消息到消息中介,test指定要接受消息的主题。 KeyedMessagedata = new KeyedMessage("test", ip, msg); //执行发送 producer.send(data); } producer.close(); }}
Producer配置参数:
metadata.broker.list:定义一个或者多个消息中介(broker),Produder通过broker决定主题leader的位置。这里无需配置所有的broker,但建议配置多于一个。 serializer.class:定义准备传递数据给broker时使用哪个序列化器。 partitioner.class:这个是可选项,该类将决定消息将发送到哪个主题分区上。 request.required.acks:该值设置为1后,broker收到消息后将发送一个确认信息给producer。
在上述程序运行之前请确保Kafka已经存在名称为test的主题,如果没有可以使用下面命令创建 bin/kafka-create-topic.sh --topic test --replica 3--zookeeper localhost:2181--partition 5然后使用下面命令查看。
标签:
相关推荐:
最新新闻:
- 推荐21个高质量图片网站 免费免版权值得收藏
- 世界最新:配置完Kafka集群后 通过JavaAPI方式来操作
- 什么是水冷机箱?水冷机箱和风冷机箱有什么区别?
- 如何解决显卡驱动无法正常安装?联想启天M6900介绍及驱动
- Office2003序列号有哪些?Office2003专业版序列号和注册码分享
- 如何屏蔽热点资讯广告提示框?热点资讯怎么彻底卸载?
- 360加速球怎样开启?加速球一直红色应该怎样解决?
- usb音箱没有声音?音响插电视上没声音怎么设置?
- 如何通过邮件群发工资条?outlook群发工资条失败咋办?
- pp助手怎么修复闪退?pp助手有什么用?
- sbsettings怎么设置?sbsettings设置的具体步骤
- Fc2视频打不开了怎么办?打开Fc2视频的步骤
- taobaoprotect.exe是什么进程?taobaoprotect.exe进程占用内存的解决方法
- java编程题:如何判断四个棋子连在一起?
- 出现此选项卡已经恢复是怎么回事?出现此选项卡已经恢复解决办法
- 全球时讯:免费下载国外视频的网站 你值得拥有
- 硬盘分区表都有什么修复方法?移动硬盘分区丢失后怎样找回?
- qq提取安装文件失败怎么办?压缩包无文件可提取咋回事?
- win10系统normal.dot在哪里?分享找到normal.dot文件的方法
- win7如何给文件设置密码?win7文件夹设置密码的具体步骤
- 如何做外链?做外链需要注意什么?
- 【体验】Xoom评测:比iPad重50克 屏幕倒更大?
- secondary logon服务是什么?开启secondary logon服务详细方法
- 每日快播:泥巴潭:《新龙族》免费卷土重来 拒绝“菜鸟玩家”
- 3dmark05怎么安装?3dmark05注册码分享
- 数学思想方法猜想与反驳 反例反驳在学习中的用处|热点
- Teracopy怎么样?Teracopy功能的及使用方法
- “东南亚小腾讯”大撤退,全面撤出欧洲市场
- 观速讯丨QQ邮箱发邮件受限制怎么办?SMTP发送邮件限制的解决方案
- 穿越时光隧道与古钓鱼城“面对面”|当前观察
- 天天热议:直降1000元 华硕 ProArt 创 16 2022 年终大促
- 游戏神U要来了 AMD居然定在情人节上市 全球观天下
- 每日简讯:最高6GHz睿频 英特尔13代酷睿i9-13900KS带来超凡体验
- 《霍格沃茨之遗》PC配置需求公布:推荐显卡1080 Ti
- FILA最好的时候已经过去?
- 当前资讯!《死亡空间:重制版》将采用2D地图 更易于使用!
- 黑鲨科技陨落,故事令人唏嘘_世界热文
- 《龙背上的农家》现已发售 Steam褒贬不一
- 【世界热闻】Q4利润增速一正一负,宁王让亿纬难望项背?| 见智研究
- 怪兽交配3D动作RPG新作《怪兽宇宙》1月上线
- 初代诞生26年 宝可梦种类现已超过1000种
- 三个月期美元Libor突破2008年金融危机期间高点 天天资讯
- 用上游戏本同款技术!联想小新Pro 16将支持独显直连
- 【环球速看料】ZOL科技早餐:英特尔6GHz睿频处理器上架,苹果新春电影《过五关》发布
- 节奏音游《节奏萌芽》2月1日全平台发售|世界快看
- 科幻Roguelike《巨人的肩膀》将于1月26日发行
- 比苹果MBP更轻 三星Galaxy Book 3 Ultra曝光
- 每日热文:木星卫星起降 NASA为创意买单
- 现代电车拥有横着走的蟹行模式
- CES总结:论性价比今年还得是买游戏本
- 武汉人的神秘邻居,有点萌:全球视讯
- 苹果新春电影《过五关》发布,用iPhone 14 Pro拍京剧,库克发文_环球速讯
- 2022年Q4传统PC出货量下降28% PC市场热潮已结束
- 《GTA:三部曲-终极版》即将登陆Steam平台:环球即时看
- 国产新冠药研发,都到哪一步了?
- 全球快报:海南文旅大盘再现违建,被罚1.23亿
- 全球速读:十倍变焦超远摄 适马60-600mm F4.5-6.3 DG DN OS发布
- 当现实中的尸体,变成你在游戏中打的丧尸-世界热门
- 天天快消息!《天龙八部之乔峰传》25日韩国上映 甄子丹将录韩版跑男
- 动作片《灭世男孩》首曝剧照 山姆·雷米监制-全球观焦点
- 国产模拟经营游戏《学园构想家》限时试玩版1月16日上线
- 世界看点:越是善解人意,越不爱社交不想聊天?
- 女子上班第一天因已婚被辞 公司赔偿100元误工费
- 快消息!《生化危机4:重制版》中配PV公开 艾达王亮相
- 纵向卡牌构筑肉鸽游戏《铁轨与墓穴》 将于2023Q1发售
- 《隐秘的角落》公布新预告 1月18日登录Steam 每日观点
- B站游戏年度榜单:国产FPS+建造《重装前哨》新预告
- 《卧龙:苍天陨落》多人物中配CG首曝 吕布霸气登场
- B站公布2022年必玩游戏榜单:法环、战神5等上榜
- 小布助手四周年幕后:主动的人让AI更主动|快报
- 类魂动作《堕落之主》中配预告公布 暗黑骑士推翻邪神_天天速看料
- 当前观点:国风生存rogue新游《通神榜》 2月14日欢乐上线
- 《NBA 2K23》第四赛季场边报告 扎克·拉文绽放光芒_环球新要闻
- 环球今热点:《师父》公布粤配预告 即将登陆Steam
- 萌蟹类魂游戏《蟹蟹寻宝奇遇》发布最新中文宣传片 年内发售 微速讯