io.debezium.util.Threads class is designed to work with SourceConnector, but there is use case where we want to utilize it within a ChangeConsumer context.

Bug report

This to to fix the bug reported here.

https://issues.redhat.com/browse/DBZ-7904

What Debezium connector do you use and what version?

2.5

What is the connector configuration?

debezium.sink.type=pubsub

What is the captured database version and mode of depoyment?

N/A

What behaviour do you expect?

Threads is util class providing threadFactory and executors, currently can be utilized only in one source connector. Though it should be generic. 

What behaviour do you see?

Threads is util class providing threadFactory and executors, currently can be utilized only in one source connector.

Do you see the same behaviour using the latest relesead Debezium version?

Yes

Do you have the connector logs, ideally from start till finish?

N/A

How to reproduce the issue using our tutorial deployment?

N/A

Feature request or enhancement

Enhancing the utility of the Threads class by making it more generic would be beneficial. Currently, it provides ThreadFactory and Executors that are tailored for use in one of source connectors. By refactoring it to be more generic, it could serve the purposes across different contexts.

Which use case/requirement will be addressed by the proposed feature?

https://github.com/debezium/debezium-server/pull/95/files

Implementation ideas (optional)

https://github.com/debezium/debezium/pull/5581