kafka-mqtt-source-connector icon indicating copy to clipboard operation
kafka-mqtt-source-connector copied to clipboard

A connector plugin to use with Kafka's Connect API. It can be configured to map any topic from an mqtt broker to any topic on the Kafka broker. The connector can be configured to use SSL in communicat...

Results 5 kafka-mqtt-source-connector issues
Sort by recently updated
recently updated
newest added

This code seems to depend on a very specific message format and cant seem to find documentation on it. ERROR MqttSourceConnectorTask ERROR: Not able to create source record from mqtt...

I setup according to the procedure specified in "Insecure - using tcp Connect Standalone". But It does not work. The content of the error message is as follows ================= mosquitto_pub...

i followed all ur steps but no luck for me, can i have your contact to talk about this please its kinda urgent to me ♥

Bumps log4j-api from 2.10.0 to 2.16.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=org.apache.logging.log4j:log4j-api&package-manager=maven&previous-version=2.10.0&new-version=2.16.0)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...

dependencies

Maybe nobody has ever tried it but... it doesn't work. The attached examples don't work either... and a quick look at the code shows why: ``` private String makeDBDoc(byte[] payload,...