The Java example for configuring KafkaMessageSource uses constructors and methods that no longer exist to set topic, group ID and client ID.