Decompression with kafka connect configuration #9931
Unanswered
suresh-tattikota
asked this question in
Q&A
Replies: 1 comment
-
I assume that if you can do it with Kafka Connect outside of Kubernetes you should be able to do it with Kafka Connect on Kubernetes. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Can we use transforms/connecters to decompress the data written to kafka topic
may be like transforms.gzipdecompression
may be same as below
transforms.HoistField.type: org.apache.kafka.connect.transforms.HoistField$Value
transforms.HoistField.field: originalValue
transforms.InsertField.type: org.apache.kafka.connect.transforms.InsertField$Value
transforms.InsertField.timestamp.field: timestamp
transforms.InsertField.static.field: message
transforms.InsertField.static.value: 'Hello World'
transforms.ReplaceField.type: org.apache.kafka.connect.transforms.ReplaceField$Value
transforms.ReplaceField.blacklist: originalValue
Beta Was this translation helpful? Give feedback.
All reactions