Staging instance, all changes can be removed at any time

Skip to content

client: allow to specify any cfg parameter to KafkaConsumer()

David Douard requested to merge generated-differential-D1608-source into generated-differential-D1608-target

directly from the config file.

This is needed because we want to be able to configure things like max_poll_records or any other kafka tuning parameter.

also parallelize the copy of objects from a polled set in content-replayer using a ThreadPoolExecutor.

Migrated from D1608 (view on Phabricator)

Merge request reports