V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX  ›  qi1070445109  ›  全部回复第 4 页 / 共 5 页
回复总数  99
1  2  3  4  5  
2019 年 1 月 3 日
回复了 quietjosen 创建的主题 分享创造 iPic 图床神器,这次是个小程序
2018 年 12 月 30 日
回复了 seaswalker 创建的主题 2019 来自 App Store 的毒鸡汤
这是什么?
2018 年 12 月 26 日
回复了 Hawstein 创建的主题 推广 圣诞节送出 5 本书和 1 个福利
算法(第 4 版)
2018 年 9 月 19 日
回复了 greyli 创建的主题 Flask 送出几本《Flask Web 开发实战》
希望能够获赠一本。
2018 年 9 月 4 日
回复了 w9ay 创建的主题 分享创造 hack-requests 基于 Python 的 http 请求库
点个赞
我消费变成 负 0.65 ,还得充 20 元去补这个。
2018 年 5 月 30 日
回复了 darksand 创建的主题 Python 请问有大佬知道怎么用 pycharm 调试 celery 吗?
@darksand 是这样,那个位置就是个 py 文件,然后你把用 os 来执行 celery 的启动命令。
2018 年 5 月 30 日
回复了 darksand 创建的主题 Python 请问有大佬知道怎么用 pycharm 调试 celery 吗?
@darksand 你把命令写脚本里不就行了?😥
2018 年 5 月 23 日
回复了 sevenQu 创建的主题 Flask flask 创建蓝图的时候,为什么如下没有产生相互引用?
目录结构呢?
2018 年 5 月 21 日
回复了 laziji 创建的主题 分享创造 无需服务器的个人博客 (更新)
@laziji 楼主,搜索能搜索全文吗?
2018 年 5 月 21 日
回复了 laziji 创建的主题 分享创造 无需服务器的个人博客 (更新)
点赞
2018 年 5 月 4 日
回复了 hbliu 创建的主题 Vim 推荐一款类 Postman 的 Vim 插件
点个赞
2018 年 4 月 9 日
回复了 mandy0119 创建的主题 Redis 关于 redis 的储存问题。
请教一下,如果用来做布隆过滤器呢?大家怎么选择? 目前是方法二。
2018 年 3 月 26 日
回复了 codeeer 创建的主题 全球工单系统 准备起诉京东了,这算实锤了吧
@codeeer 就应该一次多买几个,之前买个 nas,换了两次才好。
2018 年 3 月 16 日
回复了 xiqingongzi 创建的主题 Python Django 官网中文文档上线啦!兼译者招募
加不进去了。。。。。。
抱歉,没整好格式。

#consumer.py
from kafka import KafkaConsumer

# To consume latest messages and auto-commit offsets
consumer = KafkaConsumer('my-topic',
group_id='my-group',
bootstrap_servers=['localhost:9092'])
for message in consumer:
# message value and key are raw bytes -- decode if necessary!
# e.g., for unicode: `message.value.decode('utf-8')`
print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
message.offset, message.key,
message.value))
# producer.py

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['broker1:1234'])


for _ in range(100000):
producer.send('my-topic', b'msg'
补充一下我用的 kafka-python 1.4.1 代码如下:

#consumer.py
from kafka import KafkaConsumer

# To consume latest messages and auto-commit offsets
consumer = KafkaConsumer('my-topic',
group_id='my-group',
bootstrap_servers=['localhost:9092'])
for message in consumer:
# message value and key are raw bytes -- decode if necessary!
# e.g., for unicode: `message.value.decode('utf-8')`
print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
message.offset, message.key,
message.value))
# producer.py

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['broker1:1234'])


for _ in range(100000):
producer.send('my-topic', b'msg'
64G,不大不小。
1  2  3  4  5  
关于   ·   帮助文档   ·   自助推广系统   ·   博客   ·   API   ·   FAQ   ·   Solana   ·   1241 人在线   最高记录 6679   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 38ms · UTC 18:14 · PVG 02:14 · LAX 11:14 · JFK 14:14
♥ Do have faith in what you're doing.