Jakub Małek

The issue seems to be related to enforced json format in [azure-eventhubs-source.kamelet.yaml](https://github.com/apache/camel-kafka-connector/blob/main/connectors/camel-azure-eventhubs-source-kafka-connector/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml#L105-L107) The base64 encoding is applied in [MarshalProcessor](https://github.com/apache/camel/blob/camel-3.14.5/core/camel-support/src/main/java/org/apache/camel/support/processor/MarshalProcessor.java#L64) with [JacksonDataFormat](https://github.com/apache/camel/blob/camel-3.14.5/components/camel-jackson/src/main/java/org/apache/camel/component/jackson/JacksonDataFormat.java) in [here](https://github.com/apache/camel/blob/camel-3.14.5/components/camel-jackson/src/main/java/org/apache/camel/component/jackson/AbstractJacksonDataFormat.java#L155). It would be nice to be able...

Hi @oscerd, Thanks for replying. I understand that, but the problem is that Event Hub consumer is posting message body in bytes. So, even though the payload could already be...

I run simple test with overridden [kamelets/azure-eventhubs-source.kamelet.yaml](https://github.com/apache/camel-kafka-connector/blob/main/connectors/camel-azure-eventhubs-source-kafka-connector/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml) file in the classpath. I've removed this section: ```yaml - marshal: json: {} ``` It worked as expected, the byte array event data...

Thanks @oscerd , generally I prefer to fix the problem with PR, rather than asking. But it looks like it's more about general design of the component. I'm curious to...

Issue reported at https://github.com/apache/camel-kafka-connector/issues/1447

The maven build seems to be failing resolving dependencies. I've merged with upstream, I hope this time it will pass :)

Hi, I found myself in a need for this feature as well but the issue seem to be open for quite a while now with many references. IMHO the easiest...

I understand your concerns, but I'm thinking about it more as "you should know what you're doing" kind feature, where simply wants to customize the effective Kubernetes manifest for your...

Hi @jcustenborder - There seems to be no update in this topic, but from my end I also found those outdates Maven Central artifact a bit problematic. For folks not...

As far as I know, source connector is fetching only [batch.max.rows](https://github.com/confluentinc/kafka-connect-jdbc/blob/master/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java#L104-L109) at single poll, which is configured to `100` by default. This why connector is applying implicit ordering by incrementing...