@Target(value={METHOD,ANNOTATION_TYPE})
@Retention(value=RUNTIME)
@MessageMapping
@Documented
public @interface KafkaHandler
KafkaListener
.
See the KafkaListener
for information about permitted method signatures
and available parameters.
It is important to understand that when a message arrives, the method selection
depends on the payload type. The type is matched with a single non-annotated parameter,
or one that is annotated with @Payload
.
There must be no ambiguity - the system
must be able to select exactly one method based on the payload type.
EnableKafka
,
KafkaListener
,
KafkaListenerAnnotationBeanPostProcessor