smjn opened a new pull request, #23867: URL: https://github.com/apache/kafka/pull/23867
Add two optional fields to ShareConsumeBenchSpec: - shareGroupDLQConfig: the DLQ topic name, its PartitionsSpec and copyRecordEnable. Before the consumers start, ShareConsumeBenchWorker creates the DLQ topic, enables it for use as a DLQ, and sets the DLQ topic name and copy record configs on the share group. - recordAcknowledger: a RecordAcknowledger, following the RecordProcessor pattern, that returns the AcknowledgeType for each consumed record. RandomRecordAcknowledger is the first implementation. Its counts are reported in the worker status. recordAcknowledger makes the consumers use explicit acknowledgement mode and cannot be combined with acknowledgeType. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
