Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4525

Topic delimiter specifying by user

XMLWordPrintable

    • Icon: Feature Request Feature Request
    • Resolution: Won't Do
    • Icon: Major Major
    • None
    • None
    • core-library
    • None
    • False
    • False

      debezium-core

       

      Hello, I am going to use debezium for MySQL!

      Motivation

      Debezium-core uses dot(.) as the topic delimiter. 

       

      Goal

      So, I'd like to add a feature that specifies a topic delimiter via config. 

       

       
      TopicSelector.java

      String delimiter = connectorConfig.getTopicDelimiter();

      CommonConnectorConfig.java

          public static final Field TOPIC_DELIMITER = Field.create("topic.delimiter")
            .withDisplayName("topic delimiter")
            .withType(Type.STRING)
            .withGroup(Field.createGroupEntry(Group.ADVANCED, 30))
            .withWidth(Width.MEDIUM)
            .withDefault(DEFAULT_TOPIC_DELIMITER)
            .withDescription("Topic delimiter. Defaults to \"" + DEFAULT_TOPIC_DELIMITER + "\".")
            .withImportance(Importance.LOW);

       

              Unassigned Unassigned
              yunjoo.park Yunjoo Park (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: