BeermanagerApplication.java

@Component
@Slf4j
class BeerHandler {

	@Autowired 
	BeerRepository repo;

	@StreamListener(target=Sink.INPUT)
	public void handleBeerMessage (String message) {
		log.info("Received beer: {}", message);
		this.repo.save(new Beer(null, message, 10.0));
	}
}