Kafka customizers

• Implement KafkaCustomizer interface from de.knowis.cards.sdk.domain.config.KafkaCustomizer where:

  1. de.knowis.cards is service project base path and solution acronym.
  2. sdk.domain.config is the configuration package in the sdk that contains KafkaCustomizer interface.

• Override kafka consumer/producer configuration by implementing that interface.

  1. For kafka consumer customizer create a bean with qualifier "kafkaConsumerCustomizer".
  2. For kafka producer customizer create a bean with qualifier "kafkaProducerCustomizer".

• KafkaCustomizer interface has only one method getConfig that gets called for each kafka topic, identified by topicAlias parameter. It will also get the KafkaBinding configuration for that topic.

• Your implementation logic should return Map<String, Object> that contains the kafka configuration that you want to be used for creatng Kafka Producer / Kafka Consumer.

    public interface KafkaCustomizer {

      /**
      *
      * @param topicAlias Alias name of Event Topic
      * @param kafkaBindingConfig for that topic alias
      * @return Customized Configurations to use for that topic alias.
      */
      public Map<String, Object> getConfig(String topicAlias, KafkaBinding kafkaBindingConfig);

    }

These properties apply to both Kafka producer and consumer. Their values come from the messagehub binding secret that is linked with each topic via topic binding configuration.