Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-2146

MirrorMaker 2 on OCP doesn't properly mirror messages with headers

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 1.6.0.GA
    • 1.4.0.GA, 1.4.1.GA, 1.5.0.GA
    • None
    • None

      Currently, when Mirror Maker 2 mirrors messages with headers, it will convert all headers from the original format into Base64 encoding using the default org.apache.kafka.connect.storage.SimpleHeaderConverter. This is not intended since it changes the mirrored messages. 

       

      It should use the org.apache.kafka.connect.converters.ByteArrayConverter converter instead which keeps the headers intact. The same converter is already set as default for keys and values.

              pmellor@redhat.com Paul Mellor
              scholzj JAkub Scholz
              Lukas Kral Lukas Kral
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: