-
Notifications
You must be signed in to change notification settings - Fork 83
Open
Description
Hi, guys!
I'm connecting to a remote Kafka cluster and some topics cannot be consumed. As far as I could see consumer timeout is hardcoded here and cannot be changed:
Line 78 in a0b3bd1
private final long pollTimeoutMs = 2000; |
It would be better to pass it as maxResultsPerPartition
(for example).
Metadata
Metadata
Assignees
Labels
No labels