|
@@ -50,7 +50,6 @@ async def consume_single_message(spider):
|
|
|
consumer = get_consumer(topic, group)
|
|
consumer = get_consumer(topic, group)
|
|
|
try:
|
|
try:
|
|
|
messages = consumer.consume_message(wait_seconds=10, batch_size=1)
|
|
messages = consumer.consume_message(wait_seconds=10, batch_size=1)
|
|
|
- print(messages)
|
|
|
|
|
if messages:
|
|
if messages:
|
|
|
# 在这里消费消息，做一些数据处理分析
|
|
# 在这里消费消息，做一些数据处理分析
|
|
|
for single_message in messages:
|
|
for single_message in messages:
|
