kafka: expose fetch.min.bytes consumer config

elastic / apm-queue

Abstraction layer over Kafka / GCP PubSub Lite to produce and consume records

Apache License 2.0

6 stars 15 forks source link

kafka: expose fetch.min.bytes consumer config #442

Closed endorama closed 6 months ago

endorama commented 6 months ago

Adds FetchMinBytes setting to consumer configuration, to allow controlling the minimun number of bytes of data the server should return for a fetch request.

This setting correspond to Kafka fetch.min.bytes setting (docs).

github-actions[bot] commented 6 months ago

:warning: Warning

System-tests will not be executed for this PR because it is from a forked repository. But it will still create a successful run-system-tests status check.

endorama commented 6 months ago

CI failure does not look correlated to these changes, this is the failing test:

2024-04-22T09:56:15.3578949Z --- FAIL: TestNewProducerBasic (0.03s)
2024-04-22T09:56:15.3579819Z     --- PASS: TestNewProducerBasic/sync_true (0.02s)
2024-04-22T09:56:15.3580776Z     --- FAIL: TestNewProducerBasic/sync_false (0.01s)

Re-triggered the job to see if it was a transient failure.