[Feature][Connector-v2]add raw format with KafkaSource

[lightzhao]

Purpose of this pull request

Check list

• Code changed are covered with tests, or it does not need tests for reason:
• If any new Jar binary package adding in your PR, please add License Notice according
  New License Guide
• If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
• If you are contributing the connector code, please check that the following files are updated:
  1. Update change log that in connector document. For more details you can refer to connector-v2
  2. Update plugin-mapping.properties and add new connector information in it
  3. Update the pom file of seatunnel-dist
• Update the release-note.

[lightzhao]

@Hisoka-X @EricJoy2048 @TyrantLucifer please approve ci.

[TaoZex]

Please add UT for Raw format.

[lightzhao]

Please add UT for Raw format.
e2e has been added, please approve ci.

[ic4y]

@lightzhao Please merge the latest dev branch and resolve the conflicts.

[lightzhao]

@lightzhao Please merge the latest dev branch and resolve the conflicts.

fixed.

[lightzhao]

@TaoZex @ic4y @Hisoka-X PTAL.

[lightzhao]

Why is there such an exception? It has nothing to do with the module I submitted, and the latest code has also been merged.

[lightzhao]

@TaoZex @ic4y @EricJoy2048 @Hisoka-X PTAL.

[TyrantLucifer]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning. cc @EricJoy2048 @hailin0

[hailin0]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning. cc @EricJoy2048 @hailin0

+1

This is a duplicate feature

[lightzhao]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning.

If schema information is not set, how should field information be obtained in the transform and sink phases?

[EricJoy2048]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning.

If schema information is not set, how should field information be obtained in the transform and sink phases?

Schema is required when read message from kafka.

[EricJoy2048]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning. cc @EricJoy2048 @hailin0

+1

[lightzhao]

When we specify format as text and do not configure schema information, the record will be output as is, so I believe this modification has no meaning. cc @EricJoy2048 @hailin0

+1

I don’t understand the previous and later replies. You need to set the schema, but the alternative method is not to set it. What does it mean?