ChengXin
ChengXin
` c = Consumer({ 'bootstrap.servers': servers, 'group.id': groupid, 'auto.offset.reset': offsettype, # 'auto.offset.reset': 'latest', }) c.subscribe([topic])` When I created the consumer, I thought it would be obvious if there was no...
Is there a demo of multithreading consumption in Kafka? The order requirements are not high, just need to improve consumption efficiency on the line。 thanks
Dear scanny,Thank you very much for your reply When I do a function, I encounter a problem. First of all, I scan the text in PPT, and then replace some...