ChengXin

Results 3 issues of 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...

bug

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

question

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...