To test if a consumer is working properly, you can use the following command:
kafkacat -b kafka-cp-kafka-headless.webpush-kafka:9092 -C -o -10 -t subscriber_errors -X security.protocol=PLAINTEXT -X queue.buffering.max.messages=1000000 -X fetch.message.max.bytes=21474836 -X auto.offset.reset=earliest