-
run
docker-compose up -d -
run
RunningAverage -
produce some data with
ConsoleProducer
Consume from result topic
docker exec -it broker /usr/bin/kafka-console-consumer --topic rating-averages --bootstrap-server broker:9092 --property "print.key=true"\
--property "key.deserializer=org.apache.kafka.common.serialization.LongDeserializer" --property "value.deserializer=org.apache.kafka.common.serialization.DoubleDeserializer" --from-beginning