anuragp89 opened a new issue, #1358:
URL: https://github.com/apache/camel-kafka-connector/issues/1358
Hi Team,
I have successfully setup Camel Kafka Connector - Azure EventHub Source 1.0
build running on kubernetes environment. But every time a new message becomes
available in Event Hub, the message received in target kafka topic still shows
encrypted payload like this :
{"schema":{"type":"bytes","optional":false},"payload":"ImV5SjBiM0JwWXlJNmV5SnVZVzFsYzNCaFkyVWlPaUp6Y0VKMk1TNHdJaXdpWldSblpVNXZaR1ZFWlhOamNtbHdkRzl5SWpvaVZHVnpkRjlIY205MWNFbEVMMHhwYm1VdE1pSXNJbWR5YjNWd1NXUWlPaUpVWlhOMFgwZHliM1Z3U1VRaUxDSmxaR2RsVG05a1pVbGtJam9pVEdsdVpTMHlJaXdpZEhsd1pTSTZJazVFUVZSQkluMHNJbkJoZVd4dllXUWlPbnNpZEdsdFpYTjBZVzF3SWpveE5qVXdNekF6T0RJMU16QTBMQ0p0WlhSeWFXTnpJanBiZXlKdVlXMWxJam9pVFdGamFHbHVaUzAyTDFSbGJYQmxjbUYwZFhKbElpd2lkR2x0WlhOMFlXMXdJam94TmpVd016QXpPREkwTWprNUxDSmtZWFJoVkhsd1pTSTZJa1pzYjJGMElpd2lkbUZzZFdVaU9qZ3VNSDFkTENKelpYRWlPak45ZlE9PSI="}
Below is the connector configuration I am using :
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
name: camel-azure-eventhub-source-connector
labels:
strimzi.io/cluster: my-connect-cluster
spec:
class:
org.apache.camel.kafkaconnector.azureeventhubssource.CamelAzureeventhubssourceSourceConnector
tasksMax: 1
config:
topics: iot
camel.kamelet.azure-eventhubs-source.namespaceName: kafkalinkns
camel.kamelet.azure-eventhubs-source.eventhubName: kafkainput
camel.kamelet.azure-eventhubs-source.sharedAccessName:
iothubroutes_mfi-iot-hub
camel.kamelet.azure-eventhubs-source.sharedAccessKey: *****
camel.kamelet.azure-eventhubs-source.blobAccountName: kafkaconnectdemo
camel.kamelet.azure-eventhubs-source.blobContainerName:
eventhubkafkaconnect
camel.kamelet.azure-eventhubs-source.blobAccessKey: *****
key.converter: org.apache.kafka.connect.storage.StringConverter
value.converter: org.apache.kafka.connect.json.JsonConverter
errors.log.enable: true
errors.log.include.messages: true
I believe it is something related to how the messages are encrypted in Event
Hub internally, but ideally the clients when consuming the messages with shared
access key get the plain text messages. Does it require a special
value.converter for this scenario, I couldn't find any configuration setting to
fix it. Please help.
Thanks,
Anurag
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
