consumer rate decreasing

[arita37]

Hello,

We are using normal code as follow :
#781

consumer = topic.get_balanced_consumer()  # all default parameters...  3 balanced consumer
while True:
    try:
        for message in consumer:
              ii+=1
              msgraw = consumer.consume()
              msg    = msgraw.value.decode('utf8')
              msg    = json.loads(msg)   
              .... #very fast process
              producer.produce(json_data)
   except Exception as e : 
               print(e)

What happens :
0 min - 5 mins : Input flow is same Kafka server (test server with fixed flow).
After 5 mins: Almost half of the expected.

1. Just wondering if you have done some tests to see the consuming flow is matching kafka output ?

2. Is 1/2 of the flow matching anything in consumer config ?

Can we re-open this issue ?

[emmettbutler]

Duplicate of #790