Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Improve][Connector-V2] Fix kafka connector #2745

Merged
merged 1 commit into from
Sep 16, 2022
Merged

Conversation

hailin0
Copy link
Member

@hailin0 hailin0 commented Sep 15, 2022

  • Fix SeaTunnelRow convert to json format error
  • Rename bootstrap.server to bootstrap.servers in kafka source config
  • Remove kafka. prefix in sink producer configuration key

Purpose of this pull request

Fix kafka connector

Check list

* Fix SeaTunnelRow convert to json format error
* Rename `bootstrap.server` to `bootstrap.servers` in kafka source config
* Remove `kafka.` prefix in sink producer configuration key
Copy link
Member

@Hisoka-X Hisoka-X left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@Hisoka-X Hisoka-X merged commit 90ce385 into apache:dev Sep 16, 2022
MRYOG pushed a commit to MRYOG/incubator-seatunnel that referenced this pull request Sep 16, 2022
* Fix SeaTunnelRow convert to json format error
* Rename `bootstrap.server` to `bootstrap.servers` in kafka source config
* Remove `kafka.` prefix in sink producer configuration key
TyrantLucifer pushed a commit to TyrantLucifer/incubator-seatunnel that referenced this pull request Sep 18, 2022
* Fix SeaTunnelRow convert to json format error
* Rename `bootstrap.server` to `bootstrap.servers` in kafka source config
* Remove `kafka.` prefix in sink producer configuration key
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants