Python测试Kafka集群(pykafka)实例
作者:右介 时间:2023-05-05 20:57:56
生产者代码:
# -* coding:utf8 *-
from pykafka import KafkaClient
host = 'IP:9092, IP:9092, IP:9092'
client = KafkaClient(hosts = host)
print client.topics
# 生产者
topicdocu = client.topics['my-topic']
producer = topicdocu.get_producer()
for i in range(100):
print i
producer.produce('test message ' + str(i ** 2))
producer.stop()
消费者代码:
# -* coding:utf8 *-
from pykafka import KafkaClient
host = 'IP:9092, IP:9092, IP:9092'
client = KafkaClient(hosts = host)
print client.topics
# 消费者
topic = client.topics['my-topic']
consumer = topic.get_simple_consumer(consumer_group='test', auto_commit_enable=True, auto_commit_interval_ms=1,
consumer_id='test')
for message in consumer:
if message is not None:
print message.offset, message.value
来源:https://www.cnblogs.com/zhangtianyuan/p/7832373.html
标签:Python,Kafka,pykafka


猜你喜欢
用Python 执行cmd命令
2022-06-08 15:29:17
Python yield 小结和实例
2023-07-21 15:37:39
用Python获取摄像头并实时控制人脸的实现示例
2022-12-11 09:50:21
mysql 5.7.21 winx64安装配置方法图文教程
2024-01-28 10:32:00

利用OBJECT_DEFINITION函数来代码存档
2009-01-20 15:34:00
vscode写python时的代码错误提醒和自动格式化的方法
2023-02-25 12:54:59

Python理解递归的方法总结
2022-06-10 03:31:08
Python Django框架中表单的用法详解
2021-11-06 04:24:41

python tkinter制作用户登录界面的简单实现
2021-01-07 06:00:09

详解php中curl返回false的解决办法
2023-10-01 05:53:22
跟混乱的页面弹窗说再见
2024-06-07 16:02:05

Python Numpy 自然数填充数组的实现
2023-12-18 16:51:37
Oracle数据库及应用程序优化开发者网络Oracle
2010-07-18 13:02:00
标准的、语义的、Unobtrusive的页签tab切换
2007-11-03 13:58:00

Python Process多进程实现过程
2021-04-30 02:21:45

设计72变——寻求banner制作的变化
2009-11-12 12:56:00

mysql having用法解析
2024-01-20 00:45:28
带你深入了解数据库设计中的英文术语表
2008-12-09 14:53:00
微信小程序-滚动消息通知的实例代码
2024-04-16 10:41:16

如何使用PyTorch实现自由的数据读取
2022-06-16 12:28:16
