python kafka 生产

from pykafka import KafkaClientclass KafkaProduct():def __init__(self,hosts,topic):"""初始化实例:param hosts: 连接地址:param topic:"""self.__client = KafkaClient(hosts=hosts)self.__topic = self.__client.topics[topic.encode()]def __set_topic(self, topic):self.__topic = self.__client.topics[topic.encode()]def set_topic(self, topic):"""设置topic:param topic::return:"""self.__set_topic(topic)def get_topics(self):"""获取当前所有topic:return:"""return self.__client.topicsdef get_topic(self):"""获取当前topic:return:"""return self.__topicdef Producer(self):"""生产者对象:return:"""with self.__topic.get_producer(delivery_reports=True) as producer:next_data = ''while True:if next_data:producer.produce(str(next_data).encode())next_data = yield Truedef send_data(self,data):"""发送数据:param datas:需要传入的可迭代对象:return:"""c = self.Producer()next(c)# for i in datas:c.send(data)if __name__ == '__main__':hosts = "localhost:9092" #连接hoststopic = "test_523"K = KafkaProduct(hosts=hosts, topic=topic)  ##K.set_topic("test")  #切换设置新的topicK.get_topic()  #获取当前设置的topic#K.get_topics() #获取所有topicdata = 100912 #要发送的可迭代对象K.send_data(data)

python kafka 生产相关推荐

python kafka kerberos 验证消费生产
2019独角兽企业重金招聘Python工程师标准>>> [toc] 安装 pykafka github $ pip install pykafka$ conda install -c ...
python kafka消费实时数据,python生产和消费kafka数据
安装kafka-python pip install kafka-python 生产者 from kafka import KafkaProducer # 有时候导入包会报错,使用pip uninst ...
python使用kafka生产和消费案例
// confluent_kafka 使用案例 import json from confluent-kafka import Producertopic_name = "" co ...
Python kafka操作实例
一.基本概念 Topic:一组消息数据的标记符: Producer:生产者,用于生产数据,可将生产后的消息送入指定的Topic: Consumer:消费者,获取数据,可消费指定的Topic: Grou ...
python kafka收不到消息_python通过Pykafka库来连接kafka并收发消息
1.安装pykafka pip install pykafka 2.下载安装 git clone https://github.com/Parsely/pykafka.git 然后将下载下来的pyka ...
java利用kafka生产消费消息
2019独角兽企业重金招聘Python工程师标准>>> 1.producer程序 package com.test.frame.kafka.controller;import kaf ...
kafka生产消费原理笔记
一.什么是kafka Kafka是最初由Linkedin公司开发,是一个分布式.支持分区的(partition).多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性 ...
kafka 生产和消费信息入门
启动生产者 kafka-console-producer.sh \ --broker-list mypc01:9092,mypc02:9092,mypc03:9092 \ --topic pet 启动 ...
鉴权kafka生产端（SCRAM）
前言 kafka官网关于sasl_scram 鉴权Kafka消费端配置创建SCRAM Credentials 依赖zk,需要先启动zk,然后在zk中创建存储SCRAM 凭证: cd kafkaclu ...

python kafka 生产

python kafka 生产相关推荐

最新文章

热门文章