In PostgresStreamingChangeEventSource, we use Executors.newSingleThreadExecutor() (twice) for setting up the keep-alive thread, instead of using the proper Debezium thread factory, which results in thread names not clearly being associated to Debezium.