php操作kafka

php操作kafka----可以参照网上的安装步骤，先安装ldkafka rdkafka，然乎启动zookeeper和kafka服务器

<?php
//$conf = new Rdkafka\Producer();
//$producer = new RdKafka\Producer();
class kafka
{public $broker_list="localhost:9092";public $topic = "wuwa";public $partion = 0;protected $producer = null;protected $consumer = null;public function __construct(){$rk = new RdKafka\Producer();if(empty($rk)){throw new \Exception("producer error");}$rk->setLogLevel(LOG_DEBUG);if(!$rk->addBrokers($this->broker_list)){throw new \Exception('添加broker失败');}$this->producer=$rk;}public function sendmsg($array_message=""){/*$topic = $this->producer->newTopic($this->topic);return $topic->produce(RD_KAFKA_PARTITION_UA,$this->partion,json_encode($array_message));*/$topic = $this->producer->newTopic($this->topic);return $topic->produce(RD_KAFKA_PARTITION_UA,$this->partion,$array_message);}
}$kafuka = new Kafka();
$kafuka->sendmsg('general! welcome to distributed world!');
$kafuka->sendmsg('好好学编程，泡昌仔和劲儿弟弟!');

输出结果

general! welcome to distributed world!
好好学编程，泡昌仔和劲儿弟弟!

转载于:https://www.cnblogs.com/saintdingspage/p/11361524.html

php操作kafka相关推荐

Java操作Kafka执行不成功
使用kafka-clients操作kafka始终不成功,原因不清楚,下面贴出相关代码及配置,请懂得指点一下,谢谢! 环境及依赖 <dependency><groupId>org ...
Python 操作 Kafka --- kafka-python
kafka-python:https://github.com/dpkp/kafka-python kafka-python 文档:https://kafka-python.readthedocs.i ...
kafka java_Java操作Kafka
java操作kafka非常的简单,然后kafka也提供了很多缺省值,一般情况下我们不需要修改太多的参数就能使用.下面我贴出代码. pom.xml org.apache.kafka kafka-clie ...
kafka实战教程(python操作kafka)，kafka配置文件详解
全栈工程师开发手册 (作者:栾鹏) 架构系列文章应用往Kafka写数据的原因有很多:用户行为分析.日志存储.异步通信等.多样化的使用场景带来了多样化的需求:消息是否能丢失?是否容忍重复?消息的吞吐量 ...
c#连接kafka_c#操作kafka（上）搭建kafka环境
小伙伴们大家好,今天没有概念,也没有理论,仅仅和大家一起快速的在centos上搭建一下kafka的测试环境,测试环境嘛,不涉及集群什么的,仅仅是单节点的kafka,日后可以在这个基础上,进行集群的相关 ...
go 操作 kafka 实现发送和订阅
kafka 消息队列 kafka架构安装kafka kafak依赖zookeeper 需要先启动zk(集群) zookeeper 启动单节点启动kafka kafka配置文件 config/ser ...
Kafka学习征途：.NET Core操作Kafka
[Kafka]| 总结/Edison Zhou 1可用的Kafka .NET客户端作为一个.NET Developer,自然想要在.NET项目中集成Kafka实现发布订阅功能.那么,目前可用的Kaf ...
Python操作kafka实现数据定时推送和获取，并解决中文乱码问题
上篇介绍了kafka环境的搭建以及实现了Python如何简单操作kafka.本篇实现如何定时向kafka推送和接收数据,并解决了中文乱码问题. 设置Producer每隔5秒推送一次数据,Consume ...
云计算大数据之 Java 操作 Kafka
云计算大数据之 Java 操作 Kafka 版权声明: 本文为博主学习整理原创文章,如有不正之处请多多指教. 未经博主允许不得转载.https://blog.csdn.net/qq_42595261/ ...
kafka详解（JAVA API操作kafka、kafka原理、kafka监控）-step2
1.JAVA API操作kafka 修改Windows的Host文件: 目录:C:\Windows\System32\drivers\etc (win10) 内容: 192.168.40.150 k ...

php操作kafka

php操作kafka相关推荐

最新文章

热门文章