DBZ-5457 Deprecate legacy topic selector for all connectors

debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbTopicSelector.java

@@ -14,7 +14,9 @@
  * Factory for this connector's {@link TopicSelector}.
  *
  * @author Randall Hauch
+ * @deprecated Use {@link io.debezium.schema.DefaultTopicNamingStrategy} instead.
  */
+@Deprecated
 @ThreadSafe
 public class MongoDbTopicSelector {
 

debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/TopicSelectorTest.java

@@ -18,6 +18,7 @@
  * @author Randall Hauch
  *
  */
+@Deprecated
 public class TopicSelectorTest {
 
     private TopicSelector<CollectionId> noPrefix;

debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlTopicSelector.java

@@ -13,7 +13,9 @@
  * Factory for this connector's {@link TopicSelector}.
  *
  * @author Randall Hauch
+ * @deprecated Use {@link io.debezium.schema.DefaultTopicNamingStrategy} instead.
  */
+@Deprecated
 @ThreadSafe
 public class MySqlTopicSelector {
 
@@ -26,7 +28,6 @@ public class MySqlTopicSelector {
      *            {@code delimiter}
      * @return the topic selector; never null
      */
-    @Deprecated
     public static TopicSelector<TableId> defaultSelector(String prefix, String heartbeatPrefix) {
         return TopicSelector.defaultSelector(prefix, heartbeatPrefix, ".",
                 (t, pref, delimiter) -> String.join(delimiter, pref, t.catalog(), t.table()));

debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleTopicSelector.java

@@ -8,6 +8,10 @@
 import io.debezium.relational.TableId;
 import io.debezium.schema.TopicSelector;
 
+/**
+ * @deprecated Use {@link io.debezium.schema.SchemaTopicNamingStrategy} instead.
+ */
+@Deprecated
 public class OracleTopicSelector {
 
     public static TopicSelector<TableId> defaultSelector(OracleConnectorConfig connectorConfig) {

debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresTopicSelector.java

@@ -13,7 +13,9 @@
  * Factory for this connector's {@link TopicSelector}.
  *
  * @author Horia Chiorean (hchiorea@redhat.com)
+ * @deprecated Use {@link io.debezium.schema.SchemaTopicNamingStrategy} instead.
  */
+@Deprecated
 public class PostgresTopicSelector {
 
     public static TopicSelector<TableId> create(PostgresConnectorConfig connectorConfig) {

debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerTopicSelector.java

@@ -12,8 +12,9 @@
  * The topic naming strategy based on connector configuration and table name
  *
  * @author Jiri Pechanec
- *
+ * @deprecated Use {@link io.debezium.schema.SchemaTopicNamingStrategy} instead.
  */
+@Deprecated
 public class SqlServerTopicSelector {
 
     public static TopicSelector<TableId> defaultSelector(SqlServerConnectorConfig connectorConfig) {

debezium-core/src/main/java/io/debezium/schema/TopicSelector.java

@@ -22,7 +22,9 @@
  *
  * @param <I>
  *            The type of {@link DataCollectionId} used by a given implementation
+ * @deprecated Use {@link io.debezium.spi.topic.TopicNamingStrategy} instead.
  */
+@Deprecated
 public class TopicSelector<I extends DataCollectionId> {
 
     private final String prefix;