Kafkaで受信したメッセージを出力するようしておく
> docker exec -it cli /bin/bash
root@cli:/# kafka-console-consumer --bootstrap-server broker:29092 --topic copy-topic --group copy-group --from-beginning
> docker exec -it broker /bin/bash
root@broker:/# kafka-console-producer --broker-list broker:29092 --topic practice-topic
>{"title":"sample", "text":"example"}
>invalid message
>{"title":"hoge", "text":"fuga"}
送信したメッセージが加工されて送信されてくることが確認できる
> docker exec -it cli /bin/bash
root@cli:/# kafka-console-consumer --bootstrap-server broker:29092 --topic copy-topic --group copy-group --from-beginning
copy message - title:sample, text:example
copy message - title:hoge, text:fuga