Skip to content
This repository has been archived by the owner on May 12, 2021. It is now read-only.

Commit

Permalink
kafka-connect-mqtt: adjust kafka-console-consumer for Kafka 2.0
Browse files Browse the repository at this point in the history
Signed-off-by: Marios Andreopoulos <opensource@andmarios.com>
  • Loading branch information
andmarios committed Aug 27, 2018
1 parent 2c788f3 commit 2261489
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kafka-connect-mqtt/coyote.yml
Expand Up @@ -69,7 +69,7 @@
timeout 10
docker exec kafkaconnectmqtt_fast-data-dev_1
kafka-avro-console-consumer --bootstrap-server fast-data-dev:9092
--topic mqtt-source --from-beginning --new-consumer
--topic mqtt-source --from-beginning
--property schema.registry.url=http://fast-data-dev:8081
ignore_exit_code: true
stdout_has: [ '{"output":5,"deviceid":"plant1-room3-pod4"}', '{"output":16,"deviceid":"ship5-deck2-rack3"}' ]
Expand Down

0 comments on commit 2261489

Please sign in to comment.