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

Fix headers provided by HeaderConverter interface to http connector. … #155

Closed
wants to merge 0 commits into from

Conversation

oBJIADo
Copy link

@oBJIADo oBJIADo commented Feb 3, 2025

I have tried to use debezium server with http-sink-connecter and i have faced 2 issues:

  1. When headers are converted using the HeaderConverter interface (e.g., SimpleHeaderConverter), an error will always occur. This is because the converter, as defined by the interface, consistently returns a byte[], whereas the HttpChangeConsumer only works with String headers.
    example debezium props:
...
debezium.sink.type=http
...
debezium.format.header=clientprovided
debezium.format.header.class=org.apache.kafka.connect.storage.SimpleHeaderConverter
...
  1. When the endpoint of the server is not reachable then debezium throws npe, because the message is null.

@jpechane
Copy link
Contributor

jpechane commented Feb 4, 2025

@oBJIADo Hi, thanks for the PR! Could you please create a Jira issue describing the bug and then modify the commit message to DBZ-xxxx Fix headers provided by HeaderConverter interface to...?
We want to make sure it is correctly tracked. Also that way it will be backported to 3.0 branch too.

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.

2 participants