当前位置: 首页 > news >正文

赣州市建设工程质量监督管理站网站360推广

赣州市建设工程质量监督管理站网站,360推广,cms做的网站胡源代码,个人网站站长Kafka适合什么样的场景? 它可以用于两大类别的应用: 构造实时流数据管道#xff0c;它可以在系统或应用之间可靠地获取数据。 (相当于message queue)构建实时流式应用程序#xff0c;对这些流数据进行转换或者影响。 (就是流处理#xff0c;通过kafka stream topic和topi…Kafka适合什么样的场景? 它可以用于两大类别的应用: 构造实时流数据管道它可以在系统或应用之间可靠地获取数据。 (相当于message queue)构建实时流式应用程序对这些流数据进行转换或者影响。 (就是流处理通过kafka stream topic和topic之间内部进行变化) Kafka中文文档http://kafka.apachecn.org/ 1系统环境 a操作系统   CentOS Linux release 7.6.1810 (Core)  64位必须确保你的内存是4G以上双核CPU否则将无法新建默认命名空间。 b确保jdk环境已经安装具体教程请看  CentOS7 shell脚本安装jdk   c确保Python3和对应的pip已经安装具体教程请看 CentOS7 源码编译安装Python3.5 2执行以下命令安装Kafka并启动 wget https://archive.apache.org/dist/kafka/1.0.0/kafka_2.11-1.0.0.tgz # 下载kafka 1.0.0安装包 tar -zxvf kafka_2.11-1.0.0.tgz # 解压安装包 cd kafka_2.11-1.0.0/ # 打开kafka目录 sh bin/zookeeper-server-start.sh -daemon config/zookeeper.properties # 后台运行zookeeper sh bin/kafka-server-start.sh config/server.properties # 运行kafka服务出现 “started” 则是启动成功 3执行以下命令创建test5的topic sh bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test5 4执行以下命令创建监听test5的消息队列程序 sh bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test5 --from-beginning 5执行以下命令建发送test5消息队列的生产者程序 sh bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test5 生产者发送一些消息回车 看到消费者界面出现生产者的消息  6Python3安装kafka依赖包执行命令 “pip3 install kafka” 依赖包安装完成后创建python3消费者监听程序kafka_consumer.py from kafka import KafkaConsumer consumer KafkaConsumer(test4, bootstrap_servers[localhost:9092]) for msg in consumer:recv %s:%d:%d: key%s value%s % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)print(recv) 运行 python3 kafka_consumer.py 创建python3生产消息队列程序kafka_producer.py import json from kafka import KafkaProducer producer KafkaProducer(bootstrap_serverslocalhost:9092) msg_dict {sleep_time: 10,db_config: {database: test_1,host: xxxx,user: root,password: root},table: msg,msg: Hello World } msg json.dumps(msg_dict) producer.send(test4, bytes(msg,ascii), partition0) producer.close() 运行 “python3 kafka_producer.py”转到kafka_consumer.py运行界面看到已接收到生产程序发送过来的信息
http://wiki.neutronadmin.com/news/193802/

相关文章:

  • 高中信息技术课网站怎么做汕头中英文网站推广
  • 山西科技网站建设网页制作中的常见问题
  • 乐清建设路小学网站图片转换链接生成器
  • 淄博网站建设网宽汉口网站优化
  • 频繁从一个网站链接到另一个网站会影响百度收录么网页开发者工具怎么用
  • 做女朋友的网站学习资料网
  • 如何开发微信微网站wordpress购物分享主题
  • 图片比较多的网站怎么做中国交通建设集团有限公司
  • 网站后台构建网站付款链接怎么做
  • 厦门市建设局查询保障摇号网站网站后缀意思
  • 快速收录网站内页微信公众平台开发者文档
  • 网站备案意味着什么自动化培训网站建设
  • 做门的网站建设南宁手机建站公司
  • 自己做网站实时监控自己搭建服务器访问国外网站
  • 怎么做网站的后台维护贵州住房与城乡建设部网站
  • 酒店设计网站建设方案娱乐网站的代理怎么做
  • 文山建设5G网站万网建设网站
  • 图片 展示 网站模板百度一下就知道手机版
  • 移动电子商务网站建设网站建设策划书是有谁编写的
  • 哪个网站专门做邮轮旅游的中国建设银行官网站汽车卡
  • 建设网站出现400错误安卓市场官方版app下载
  • 多终端网站网站建设要学多少课程
  • 西安推荐企业网站制作平台北京网站建设的价格天
  • 本土建站工作室wordpress 整体搬家
  • 电子商务网站建设精英如何在手机上制作动画
  • 本地wordpress 跳转包头seo优化
  • 常州微网站建设网站模板开发
  • 太和县建设局网站网站首页模板下载
  • 斗鱼网站开发是用什么语言石家庄网站建设服务
  • 如何用七牛云做视频网站批量上传 wordpress