I’ve been working on a migration from Spring 2.X to 3.X and my old code used @EnableBinding(Sink::class) and @StreamListener(Sink.INPUT) in the consumer. With both being deprecated and removed from the consumer the following error occurs when my Kafka Tests using the consumer are run: