bjethwan opened a new issue, #980:
URL: https://github.com/apache/camel-kamelets/issues/980
ISSUE WITH KAMELET azure-servicebus-source output is message length instead
of message
I had below KameletBinding working with Timer source but with Azure
ServiceBus.
I was getting a type conversion error
Caused by: org.apache.camel.NoTypeConversionAvailableException: No type
converter available to convert from type: com.azure.core.util.BinaryData to the
required type: java.io.InputStream
Hence, I added a JSON Serializer in between
```
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: aws-s3-streaming-upload-sink-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: azure-servicebus-source
properties:
connectionString:
Endpoint=<<>>/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=<<>>
topicOrQueueName: <<>>
serviceBusReceiveMode: RECEIVE_AND_DELETE
steps:
- ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: json-serialize-action
sink:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: aws-s3-streaming-upload-sink
properties:
bucketNameOrArn: arn:aws:s3:::<<>>
keyName: timer-source
region: ap-south-1
accessKey: <<>>
secretKey: <<>>
batchMessageNumber: 5
```
Now the PROBLEM is that instead of capturing data it's capturing length of
the message
{"length":54}{"length":54}{"length":54}{"length":54}{"length":54}
How to fix this?
Do I need to configure the azure-servicebus-source Kamelet to make it output
String/JSON? Is it reasonable to configure the Kamelet or should I copy and
configure that one?
--
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]
