python kafka 多線程消費者&手動提交

官方文檔：https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.htmlhtml import threading import os import sys from kafka import KafkaConsumer, TopicPartition, OffsetAndMetadata from consume

>>阅读原文<<