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.

Sign up for GitHub

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

Jump to bottom

chore: Add header deserialize option on Kafka source #842

Merged
merged 2 commits into from
Mar 29, 2022
Merged

chore: Add header deserialize option on Kafka source #842

merged 2 commits into from
Mar 29, 2022

Commits on Mar 21, 2022

  1. chore: Add header deserialize option on Kafka source 

    - Adds utility class to auto deserialize message headers from byte[] to String
- Option must be explicitly enabled on the source Kamelet
- Exclude non String Kafka headers from deserialization (kafka.HEADERS and CamelKafkaManualCommit)
    @christophd
    christophd committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    2539572 View commit details
    Browse the repository at this point in the history

  2. chore: Kafka source uses local bean for header deserialization

    @christophd
    christophd committed Mar 21, 2022
    Configuration menu
    Copy the full SHA
    eacc9e3 View commit details
    Browse the repository at this point in the history