Consumer group record fetch rate

2018-04-22 Thread Jamie Park
Hi I am puzzled on this consumer group behavior. I have 40 consumers within a single consumer group with large lags. We are looking to increase partitions and number of consumers as lags indicate our records are produced faster than this consumer group can consume. However I observed thi

[jira] [Created] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

2018-04-22 Thread taekyung kim (JIRA)
taekyung kim created KAFKA-6815: --- Summary: "default.production.exception.handler" default value is not specified correctly in KafkaStream doc Key: KAFKA-6815 URL: https://issues.apache.org/jira/browse/KAFKA-6815

[jira] [Created] (KAFKA-6814) Bad exception message for GroupIdNotFoundException/GroupNotEmptyException

2018-04-22 Thread huxihx (JIRA)
huxihx created KAFKA-6814: - Summary: Bad exception message for GroupIdNotFoundException/GroupNotEmptyException Key: KAFKA-6814 URL: https://issues.apache.org/jira/browse/KAFKA-6814 Project: Kafka Is