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

Topic delimiter specifying by user

    XMLWordPrintable

Details

    • Feature Request
    • Status: Closed (View Workflow)
    • Major
    • Resolution: Won't Do
    • None
    • None
    • core-library
    • None
    • False
    • False

    Description

      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); 

       

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: