kafka php使用,kafka设置队列优先级？

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

将优先级统一设定为高、中、低三个级别。具体操作方案如下：

1. 对某个优先级根据 task (单次推送任务)维度，存入不同的 Topic，一个 task 只写入一个 Topic，一个 Topic 可存多个 task；

2. 消费模块根据优先级配额(如 6:3:1)，获取不同优先级的消息数，同一优先级轮询获取消息；这样既保证了高优先级用户可以更快地发送消息，又避免了低优先级用户出现没有下发的情况。

kafka 不能脱离 zookeeper 单独使用，

因为 kafka 使用 zookeeper 管理和协调 kafka 的节点服务器。

kafka 有两种数据保存策略：

按照过期时间保留

按照存储的消息大小保留。

不可能越过Zookeeper直接联系Kafka broker，一旦Zookeeper停止工作，它就不能服务客户端请求。

Zookeeper主要用于在集群中不同节点之间进行通信，在Kafka中，它被用于提交偏移量

在使用Kafka时，可以通过订阅主题的方式来消费消息。具体操作步骤如下：

1. 创建Kafka消费者对象：使用Kafka API创建一个消费者对象，同时设置所需的属性和参数，例如连接地址、订阅主题名称等。

2. 订阅主题： 使用消费者对象调用subscribe()方法来订阅指定的主题。您可以通过指定单个主题或多个主题名称的列表来实现订阅。

3. 接收消息： 在成功订阅主题后，使用poll()方法接收并处理相应的消息。poll()方法会返回一个ConsumerRecord对象，其中包含了消息内容和相关的元数据信息。

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_php使用”的问题就介绍到这了，希望介绍关于“kafka_php使用”的【4】点解答对大家有用。