用最简单的例子告诉你kafka是怎么用的

1、首先打开zookeeper集群和kafka集群，三台都开上

2、创建 Kafka 主题 call（在任意几点创都可以）

kafka-topics.sh --zookeeper hadoop01:2181 --topic call --create --replication-factor 1 --partitions 3

我这里已经创好了，所以他报错了

3、检查 call 主题是否创建成功

kafka-topics.sh --zookeeper hadoop01:2181 --list

4、在hadoop01节点上创建一个生产者

kafka-console-producer.sh --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic call

任一节点都可以不要纠结
5、在hadoop02上创建一个消费者

kafka-console-consumer.sh --bootstrap-server hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic call

6、生产者传入数据
7、消费者接受
会用了来个赞呗

用最简单的例子告诉你kafka是怎么用的相关推荐

【李宏毅2020 ML/DL】P10 Classification_1 | 简单的例子告诉你使用 wx+b 以及 Sigmoid 作为激活函数的合理性
我已经有两年 ML 经历,这系列课主要用来查缺补漏,会记录一些细节的.自己不知道的东西. 已经有人记了笔记(很用心,强烈推荐): https://github.com/Sakura-gh/ML-not ...
用简单的例子说明提升可复用性的设计模式
此文写给想要理解设计模式,但认为<设计模式>中所举的例子过于复杂的读者. 为了使程序具有更高的可复用性,前人推荐我们使用如下设计模式: 结构型模式:通过组合类和对象来获得更大的结构 1. ...
扩展Python模块系列(二)----一个简单的例子
本节使用一个简单的例子引出Python C/C++ API的详细使用方法.针对的是CPython的解释器. 目标:创建一个Python内建模块test,提供一个功能函数distance, 计算空间中两 ...
用一个简单的例子来阐述强化学习的相关概念（二）
什么是强化学习? 强化学习是Agent玩家在与环境的互动当中,为了达成目标而进行了学习过程.这是强化学习的第1层结构,称之为基本元素,包括第一Agent玩家,第二Environment环境,第三个Go ...
理解神经网络，从简单的例子开始（2）使用python建立多层神经网络
这篇文章将讲解如何使用python建立多层神经网络.在阅读这篇文章之前,建议先阅读上一篇文章:理解神经网络,从简单的例子开始.讲解的是单层的神经网络.如果你已经阅读了上一篇文章,你会发现这篇文章的代码 ...
理解神经网络，从简单的例子开始（1）7行python代码构建神经网络
理解神经网络,从简单的例子开始(1)7行python代码构建神经网络前言本文分为两个部分,第一个部分是一个简单的实例:9行Python代码搭建神经网络,这篇文章原文为:原文链接, 其中中文翻译版来 ...
.net中的对象序列化(1)：序列化是什么, 以及一个简单的例子
1. 为什么需要序列化,什么是序列化对于一个程序来说, 使用到的对象都是存在于内存中的.如果想保存这些对象的运行时状态, 或者需要在不同进程或者网络间传递对象,就需要序列化. 序列化就是讲运行中的对 ...
CSharpGL(1)从最简单的例子开始使用CSharpGL
CSharpGL(1)从最简单的例子开始使用CSharpGL 2016-08-13 由于CSharpGL一直在更新,现在这个教程已经不适用最新的代码了.CSharpGL源码中包含20多个独立的Demo ...
一个简单的例子看java线程机制
一个简单的例子看java线程机制作者: zyf0808 发表日期: 2006-03-26 11:20 文章属性: 原创复制链接 import java.util.*; public class T ...
java ug二次开发_使用Java进行UG二次开发：简单的例子（上） | 学步园
最近因为要进行TeamCenter二次开发(胖客户端定制),所有要开始研究Java了.因此突发奇想为什么不能使用Java进行二次开发呢?现在对UG进行的开发以C/C++应用为主.大多数使用的是原来的U ...

用最简单的例子告诉你kafka是怎么用的

用最简单的例子告诉你kafka是怎么用的相关推荐

最新文章

热门文章