kafka的使用与负载均衡(Windows环境)

  • 时间:
  • 浏览:0
  • 来源:uu快3骗局_uu快3心得_开奖

测试一下容错能力.Broker 2作为leader运行,现在我门关掉它:

我的是 broker 2

看来kafka的容错机制还是很不错的!!

3.StreamAPI:允许应用扮演流避免的作用,从另3个 或多个topic里消费数据流,随后产生输出流数据到你这种 另3个 或多个topic里,对输入流数据有效传输到输出口;

刚才可能性启动可Zookeeper和另3个 节点,现在启动另外另3个 节点:

4.ConnectorAPI:允许运行和构建另3个 可重复利用的生产者和消费者,能将kafka的topic与你这种 存在的应用和数据库设备相连接,比如链接另3个 实时数据库,须要捕捉到每张表的变化。

2.ConsumerAPI:允许另3个 应用订阅另3个 或多个topics,避免topic里的数据流,就合适消费;



随后关闭server-2.properties的cmd

结果变成了0

下面解释一下哪几个输出。第一行是对所有分区的另3个 描述,随后每个分区都是对应一行,可能性我门能够另3个 分区什么都下面就只加了一行。

须要通过list命令查看创建的topic:

1.ProducerAPI:允许另3个 应用向另3个 或多个topic里发布记录流;

1.首先创建3份server.properties文件



你这种 版本的消费消息写法

消费哪几个消息

创建另3个 拥有3个副本的topic:

在windows上使用会突然出现 zookeeper is not a recognized option你你这种 错误

着实最初负责续写消息的leader down掉了,但以前的消息还是须要消费的:

leader:负责避免消息的读和写,leader是从所有节点中随机选折 的.

replicas:列出了所有的副本节点,不管节点否是在服务中.

isr:是正在服务中的节点.

向topic发送消息:

Kafka是另3个 分布式的、可分区的、可一键复制的消息系统。它提供了普通消息系统的功能,但具有此人 独特的设计。它须要像消息系统一样读写数据流,随后须要在实时业务的场景中写可靠的流避免应用,之能够安全地存储数据流到分布式、多副本、容错的集群中。什么都通俗点理解,须要说Kafka只是另3个 消息中间件。

查看topics的集群节点信息

创建另3个 叫做“test”的topic,它能够另3个 分区,另3个 副本。

随后输入消息

按Ctrl+C须要现在结束消息发送

注意配置文件中这麼port你你这种 项配置

注意:windows版本的kafka要进入/bin/windows文件夹下