Skip to content

CamelSinkTask headers must be cleaned before sending them ahead #223

Closed
@oscerd

Description

@oscerd

https://github.com/apache/camel-kafka-connector/blob/master/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java#L117

Actually we are sending the header with the prefix set for distinguishing between camel headers and kafka headers, but we need to remove the prefix before going ahead.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions