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

Topic delimiter specifying by user

    XMLWordPrintable

Details

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

    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

          relates to

          Enhancement - An enhancement to or refactoring of existing functionality that is not configurable by an end user (typically a change made by an internal team that affects users) DBZ-4180 Pluggable topic selector

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          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: