J'utilise actuellement cette lib à un test de serveur kafka que j'ai mis en place: https://github.com/dsully/pykafka import kafka
import time
def test_kafka_server(n=1):
for i in range(0,n):
J'utilise la propriété queuedchunks.max pour récupérer 10 messages du sujet à la fois, mais il retourne tous les messages disponibles (plus de 10) .S'il vous plaît me faire savoir s'il y est un moyen