public abstract class CallbackListener {

    @Target({ ElementType.TYPE })
    @Retention(RetentionPolicy.RUNTIME)
    @KafkaListener(id = LISTENER_ID, idIsGroup = false)
    public @interface CallbackListenerDef {

        @AliasFor(annotation = KafkaListener.class)
        String[] topics() default {};

        // This was missing: @AliasFor(annotation = KafkaListener.class)
        String groupId() default "${spring.kafka.consumer.group-id}.callback";
    }

    @KafkaHandler(isDefault = true)
    public void executeCallback(CallbackEvent event) {
        // ...
    }

    @Service
    @Profile("!mock")
    @CallbackListenerDef(topics = TOPIC)
    public static class ProdCallbackListener extends CallbackListener {
    }

    @Service
    @Profile("mock")
    @CallbackListenerDef(topics = TOPIC_MOCK, groupId = "${spring.kafka.consumer.group-id}.callback-mock")
    public static class MockCallbackListener extends CallbackListener {
    }
}