[Spark][kafka]kafka 生产者，消费者互动例子-低调大师

[Spark][kafka]kafka 生产者，消费者互动例子

2017-12-26 552

[Spark][kafka]kafka 生产者，消费者互动例子

# pwd
/usr/local/kafka_2.11-0.10.0.1/bin

创建topic:
# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic device_status
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic "device_status".
#

查看topic:
# ./kafka-topics.sh --list --zookeeper localhost:2181
device_status
#

生产者生成消息：
# ./kafka-console-producer.sh --broker-list localhost:9092 --topic device_status

消费者获得消息：
# pwd
/usr/local/kafka_2.11-0.10.0.1/bin

# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic device_status --from-beginning

在生产者窗口输入：
hi, I am producer 然后按回车

在消费者窗口会看到：
hi, I am producer

本文转自健哥的数据花园博客园博客，原文链接：http://www.cnblogs.com/gaojian/p/7675717.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/354912

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Hadoop手把手逐级搭建(1) 单机伪分布

第一阶段: Hadoop单机伪分布(single) 0. 步骤概述 1). 配置网络修改主机名 2). 配置ssh免密码登录 3). 安装jdk 4). 安装hadoop 5). 配置hadoop单机伪分布运行环境(不使用yarn) 6). 为hadoop单机伪分布增加yarn配置 1. 配置网络修改主机名 1.1 查看VMware虚拟网络 1.1.1 点击VMware菜单“编辑(E)” 1.1.2 在下拉菜单列表选择“虚拟网络编辑器” 1.1.3 在弹出的“虚拟网络编辑器”窗口右下角选择“更改设置(C)” 1.1.4 如果windows弹出的安全提示选择“是” 1.1.5 在窗口上方重新刷新的网络列表里选中“NAT模式”，窗口中间的“WMnet信息”下，复选框会默认选中“NAT模式(与虚拟机共享主机的IP地址)(N)” 1.1.6 点击“NAT设置(S)…” 1.1.7 在弹出的“NAT设置”窗口可以查看到如下信息：网络VMnet8 子网IP：192.168.111.0 子网掩码：255.255.255.0 网关IP(G)：192.168.111.2 #使用上述信息配置网卡相关属性...

2017-12-26

522

信息摘要： HBase本地盘规格，适配大容量存储场景，降低存储费用。适用客户：海量数据存储场景：车联网、物联网、金融证券、IOT、风控版本/规格功能： HBase 本地盘规格，当前上线HDD系列，专注于低成本的大数据量存储解决方案。低成本优势：针对大数据量存储分析场景，若数据量达到几十TB甚至PB级别，使用常规云盘存储方案每年成本将高达三五百万。最新的HBase本地HDD盘系列规格，将每GB成本降低为云盘的十分之一，可以为企业优化90%的数据存储成本。高可扩展性：HBase服务支持无上限横向扩容节点（计算+存储资源），可轻松应对企业级上百TB乃至PB级别的数据存储分析。产品文档： https://help.aliyun.com/document_detail/53532.html?spm=5176.product49055.

2017-12-27

544

资源下载

更多资源

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。