Right now ExtractNewRecordState.java is tightly coupled and implemented based on Kafka. We are using Debezium with Apache Pulsar for CDC but one missing feature is the Record Transformation in producer side before publishing to the topic.

As per the Apache Pulsar Transformation support in Github issue, tight coupling nature of ExtractNewRecordState with Kafka is a blocker. Instead of writing our implementation of ExtractNewRecordState for Pulsar, it would be best to Generify the ExtractNewRecordState class in debezium to support any messaging system (which should be configurable at connector setup).

PS: The comment in the provided Github issue link is by official maintainer / contributor of Apache Pulsar. I am just an end user of Apache Pulsar.