Composite annotation that applies required property overrides and proxies other commonly used parameters to meta annotations.

PayNotificationListener.java

package com.booking.payments.point.common.core.annotation;

import com.booking.payments.point.common.core.model.MetricNames;
import io.micrometer.core.annotation.Timed;
import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.core.annotation.AliasFor;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * Composite annotation for Kafka Consumers of the pay-notifications topics.
 * - Applies kafka-client property overrides required for cluster-discovery (used in booking-kafka-clients).
 * - Applies a {@link Timed} annotation.
 * Proxies all other commonly used parameters to original annotations.
 */
@Target({ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Timed
@KafkaListener(
    properties = {
        "cluster.dc = ${pay-notifications.kafka-cluster.dc}",
        "cluster.env = ${pay-notifications.kafka-cluster.env}",
    }
)
public @interface PayNotificationListener {
  @AliasFor(annotation = Timed.class, attribute = "value")
  String metricName() default MetricNames.UOW_PAY_NOTIFICATION_BATCH;

  @AliasFor(annotation = KafkaListener.class, attribute = "topics")
  String[] topics();

  @AliasFor(annotation = KafkaListener.class, attribute = "clientIdPrefix")
  String clientIdPrefix() default "pay-notifications";

  @AliasFor(annotation = KafkaListener.class, attribute = "concurrency")
  String concurrency() default "";
}