lhotari commented on code in PR #23078:
URL: https://github.com/apache/pulsar/pull/23078#discussion_r1696469791
##########
pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java:
##########
@@ -52,12 +52,12 @@
import org.apache.pulsar.client.api.Schema;
/**
- * A {@link DatabaseHistory} implementation that records schema changes as
normal pulsar messages on the specified
+ * A {@link SchemaHistory} implementation that records schema changes as
normal pulsar messages on the specified
* topic, and that recovers the history by establishing a Kafka Consumer
re-processing all messages on that topic.
*/
@Slf4j
@ThreadSafe
-public final class PulsarDatabaseHistory extends AbstractDatabaseHistory {
+public final class PulsarDatabaseHistory extends AbstractSchemaHistory {
Review Comment:
nvm. found the answer, [DBZ-5043 Replace 'database history' with 'database
schema
history'](https://github.com/debezium/debezium/commit/b6c31f3da5559777a42eada8ccc18cde7e8bbc1f)
--
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]
