Skip to content

[INLONG-7299][Sort] Optimize the options check for the Kafka connector#7471

Merged
dockerzhang merged 1 commit intoapache:masterfrom
dockerzhang:fix-7299
Mar 1, 2023
Merged

[INLONG-7299][Sort] Optimize the options check for the Kafka connector#7471
dockerzhang merged 1 commit intoapache:masterfrom
dockerzhang:fix-7299

Conversation

@dockerzhang
Copy link
Contributor

@dockerzhang dockerzhang commented Mar 1, 2023

Prepare a Pull Request

(Change the title refer to the following example)

  • Title Example: [INLONG-XYZ][Component] Title of the pull request

(The following XYZ should be replaced by the actual GitHub Issue number)

Motivation

Explain here the context, and why you're making that change. What is the problem you're trying to solve?

Modifications

  • All supported formats are checked in ExtractNodeUtils.parsingFormat(), so it does not need to check again for Kafka ExtractNode.
  • Add valueFormatPrefix check for `inlong-msg.' prefix options.
    image

@dockerzhang dockerzhang requested review from gong, thexiay and yunqingmoswu and removed request for gong and yunqingmoswu March 1, 2023 03:06
@featzhang
Copy link
Member

LGTM

@featzhang
Copy link
Member

+1

@dockerzhang dockerzhang merged commit 7116856 into apache:master Mar 1, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Feature][Sort][Manager] Support InLongMsg in KafkaConnector

5 participants