kafka: error while consuming TestTopic/0: kafka server: Request exceeded the user-specified time limit in the request

1k Views Asked by At

Helo,

"kafka: error while consuming TestTopic/0: kafka server: Request exceeded the user-specified time limit in the request."

I am getting the above error intermittently while consuming from kafka broker(i.e kafka) OR GCP Pub Sub(i.e gcp_pubsub) pubsub on topic "TestTopic" via Benthos kafka input configuration as below(for input kafka):

input:
  broker:
    inputs:
      - kafka:
          addresses:
            - ${KAFKA_BOOTSTRAP_SERVERS:localhost:9092}
          topics: 
            - TestTopic
          client_id: clientIdTest
          consumer_group: consumerGroupTest
          checkpoint_limit: 2000
          batching:
            count: 1000
            byte_size: 10485760
            period: "1s"
0

There are 0 best solutions below