April 2018
Intermediate to advanced
432 pages
10h 38m
English
To enable Apache Kafka for the application, include the spring-cloud-starter-stream-kafka starter to the dependencies. Our current sample is very similar to to the sample of publish/subscribe using with RabbitMQ publish/subscribe with grouping and partitioning presented in The publish/subscribe model, section. The only difference is in the dependencies and configuration settings.
Spring Cloud Stream automatically detects and uses a binder found on the classpath. The connection settings may be overridden with spring.kafka.* properties. In our case, we just need to change the auto-configured Kafka client address to the Docker machine address 192.168.99.100. The same modification should be performed for Zookeeper, ...