See https://github.com/spring-projects/spring-kafka/issues/2318 Gateway should wait for assignment of partitions in reply container before sending request/reply messages.