算法（第 4 版）

希望能够获赠一本。

点个赞

我消费变成 负 0.65 ，还得充 20 元去补这个。

@darksand 是这样，那个位置就是个 py 文件，然后你把用 os 来执行 celery 的启动命令。

@darksand 你把命令写脚本里不就行了？😥

目录结构呢？

@laziji 楼主，搜索能搜索全文吗？

点赞

点个赞

请教一下，如果用来做布隆过滤器呢？大家怎么选择？ 目前是方法二。

@codeeer 就应该一次多买几个，之前买个 nas，换了两次才好。

加不进去了。。。。。。

抱歉，没整好格式。

#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，不大不小。

@ioriwong Good ！