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

  • 时间:
  • 浏览:0

4.ConnectorAPI:允许运行和构建有另六个 可重复利用的生产者和消费者,能将kafka的topic与或多或少发生的应用和数据库设备相连接,比如链接有另六个 实时数据库,都时需捕捉到每张表的变化。

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

刚才不可能 启动可Zookeeper和有另六个 节点,现在启动另外有另六个 节点:

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

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

都时需通过list命令查看创建的topic:

下面解释一下那此输出。第一行是对所有分区的有另六个 描述,后来每个分区后会对应一行,不可能 或多或少人必须有另六个 分区全都下面就只加了一行。

人太好最初负责续写消息的leader down掉了,但后后的消息还是都时需消费的:

leader:负责正确处理消息的读和写,leader是从所有节点中随机取舍的.

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

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

向topic发送消息:

3.StreamAPI:允许应用扮演流正确处理的作用,从有另六个 或多个topic里消费数据流,后来产生输出流数据到或多或少有另六个 或多个topic里,对输入流数据有效传输到输出口;

在windows上使用会出先zookeeper is not a recognized option这人 错误

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

Kafka是有另六个 分布式的、可分区的、可好友克隆的消息系统。它提供了普通消息系统的功能,但具有买车人独特的设计。它都时需像消息系统一样读写数据流,后来都时需在实时业务的场景中写可靠的流正确处理应用,然都后能 安全地存储数据流到分布式、多副本、容错的集群中。全都通俗点理解,都时需说Kafka却说有另六个 消息上边件。

后来输入消息

按Ctrl+C都时需现在开始消息发送

测试一下容错能力.Broker 2作为leader运行,现在或多或少人关掉它:

我的是 broker 2

消费那此消息

创建有另六个 叫做“test”的topic,它必须有另六个 分区,有另六个 副本。

2.ConsumerAPI:允许有另六个 应用订阅有另六个 或多个topics,正确处理topic里的数据流,就共要消费;



后来关闭server-2.properties的cmd

结果变成了0

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

查看topics的集群节点信息

注意配置文件中这么port这人 项配置



或多或少版本的消费消息写法