V2EX › qi1070445109 的所有回复 › 第 5 页 / 共 6 页

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

1 2 3 4 5 6

❮

❯

2018 年 3 月 8 日

回复了 qi1070445109 创建的主题 › Kafka › kafka 重启后， kafka- Python 消费者需要重启才能订阅 topic

抱歉，没整好格式。

#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'

2018 年 3 月 8 日

回复了 qi1070445109 创建的主题 › Kafka › kafka 重启后， kafka- Python 消费者需要重启才能订阅 topic

补充一下我用的 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'

2018 年 3 月 6 日

回复了 cantonadong 创建的主题 › Android › 不下视频，偶尔拍照，使用的 app 大概 50~70 个左右，买 32 还是 64 容量？

64G，不大不小。

2018 年 2 月 16 日

回复了 2moldream 创建的主题 › 职场话题 › 一点工作上的事情

@ioriwong Good ！

2018 年 2 月 16 日

回复了 radiofloyd 创建的主题 › 职场话题 › 刚毕业，已经跳槽一次，又想跳槽了，怎么办

同意 13 楼。

2018 年 2 月 16 日

回复了 leomon 创建的主题 › 职场话题 › 年底了准备谈下老铁们给分析下

看了你们的回复，我感觉我太幼稚了。