Package ch.admin.bit.jeap.messaging.kafka.auth.aws.iam

Class AwsMskKafkaAuthProperties

java.lang.Object

ch.admin.bit.jeap.messaging.kafka.auth.aws.iam.AwsMskKafkaAuthProperties

All Implemented Interfaces:

ch.admin.bit.jeap.messaging.kafka.auth.KafkaAuthProperties

public class AwsMskKafkaAuthProperties
extends Object
implements ch.admin.bit.jeap.messaging.kafka.auth.KafkaAuthProperties

Constructor Summary

Constructors

Constructor	Description
AwsMskKafkaAuthProperties(ch.admin.bit.jeap.messaging.kafka.properties.KafkaProperties kafkaProperties)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	authenticationProperties(String clusterName)	Configuration properties for Kafka clients using AWS MSK with IAM authentication.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AwsMskKafkaAuthProperties

public AwsMskKafkaAuthProperties(ch.admin.bit.jeap.messaging.kafka.properties.KafkaProperties kafkaProperties)

Method Details

authenticationProperties

public Map<String,Object> authenticationProperties(String clusterName)

Configuration properties for Kafka clients using AWS MSK with IAM authentication. See README.

Specified by:

authenticationProperties in interface ch.admin.bit.jeap.messaging.kafka.auth.KafkaAuthProperties