kafkaphp,kafka原理和架构解析？

关于“kafka.php”的问题，小编就整理了【4】个相关介绍“kafka.php”的解答：

Kafka是一种分布式流处理平台，它具有高吞吐量、可扩展性和持久性的特点。下面是Kafka的原理和架构解析：

1. 基本概念：

○ Topic（主题）：消息的类别或者主题，可以理解为消息的容器。

○ Producer（生产者）：负责向Kafka的Topic发送消息。

○ Consumer（消费者）：从Kafka的Topic订阅并消费消息。

○ Broker（代理）：Kafka集群中的每个节点，负责存储和处理消息。

○ Partition（分区）：每个Topic可以分为多个分区，每个分区在不同的Broker上存储。

○ Offset（偏移量）：每个消息在分区中的唯一标识。

2. 架构：

○ Kafka集群由多个Broker组成，每个Broker可以在不同的机器上。

○ 每个Topic可以分为多个Partition，每个Partition在不同的Broker上存储。

○ 每个Partition都有一个Leader和多个Follower，Leader负责处理读写请求，Follower用于备份数据。

○ Producer将消息发送到指定的Topic，Kafka将消息写入对应Partition的Leader副本，并返回写入成功的响应。

http

HTTP是一个简单的请求-响应协议，它通常运行在TCP之上。它指定了客户端可能发送给服务器什么样的消息以及得到什么样的响应。请求和响应消息的头以ASCII码形式给出；而消息内容则具有一个类似MIME的格式。这个简单模型是早期Web成功的有功之臣，因为它使得开发和部署是那么的直截了当。

kafka释义：

n. 卡夫卡（奥地利小说家）

例句：

Why do judges cite Shakespeare or Kafka?

法官有什么必要引用莎士比亚或卡夫卡呢？

1、进入kafka的执行目录

cd /opt/cloudera/parcels/KAFKA-3.1.0-1.3.1.0.p0.35/lib/kafka/

2、查看所有的kafka topic列表:

bin/kafka-topics.sh -zookeeper hadoop-5:2181,hadoop-6:2181 -list

3、查看kafka特定topic详情，使用--topic与--describe参数

bin/kafka-topics.sh -zookeeper hadoop-5:2181,hadoop-6:2181 --topic ztjy.dt.log.adv --describe

kafka 有两种数据存储策略:

1、按照过期时间保留

2、按照存储的消息大小保留

Kafka Broker默认的消息保留策略是：要么保留一定时间，要么保留到消息达到一定大小的字节数。

当消息达到设置的条件上限时，旧消息就会过期并被删除，所以，在任何时刻，可用消息的总量都不会超过配置参数所指定的大小。

topic可以配置自己的保留策略，可以将消息保留到不再使用他们为止。

到此，以上就是小编对于“kafka.php”的问题就介绍到这了，希望介绍关于“kafka.php”的【4】点解答对大家有用。