Uses of Class
org.apache.camel.component.kafka.security.KafkaSecurityConfigurer
Packages that use KafkaSecurityConfigurer
-
Uses of KafkaSecurityConfigurer in org.apache.camel.component.kafka.security
Methods in org.apache.camel.component.kafka.security that return KafkaSecurityConfigurerModifier and TypeMethodDescriptionstatic KafkaSecurityConfigurerKafkaSecurityConfigurer.awsMskIam()Creates a new security configurer for AWS MSK IAM authentication.static KafkaSecurityConfigurerKafkaSecurityConfigurer.forAuthType(KafkaAuthType authType) Creates a new security configurer for the specified authentication type.static KafkaSecurityConfigurerCreates a new security configurer for Kerberos authentication.static KafkaSecurityConfigurerKafkaSecurityConfigurer.noAuth()Creates a new security configurer for no authentication.static KafkaSecurityConfigurerCreates a new security configurer for OAuth 2.0 authentication.static KafkaSecurityConfigurerCreates a new security configurer for PLAIN authentication.static KafkaSecurityConfigurerKafkaSecurityConfigurer.scramSha256(String username, String password) Creates a new security configurer for SCRAM-SHA-256 authentication.static KafkaSecurityConfigurerKafkaSecurityConfigurer.scramSha512(String username, String password) Creates a new security configurer for SCRAM-SHA-512 authentication.static KafkaSecurityConfigurerKafkaSecurityConfigurer.ssl()Creates a new security configurer for SSL/mTLS authentication.KafkaSecurityConfigurer.withCredentials(String username, String password) Sets username and password credentials.KafkaSecurityConfigurer.withCustomJaasConfig(String jaasConfig) Sets a custom JAAS configuration string.KafkaSecurityConfigurer.withKerberos(String principal, String keytab) Configures Kerberos authentication parameters.KafkaSecurityConfigurer.withKerberosStoreKey(boolean storeKey) Sets whether to store the Kerberos key.KafkaSecurityConfigurer.withKerberosUseKeyTab(boolean useKeyTab) Sets whether to use keytab for Kerberos authentication.Configures OAuth 2.0 authentication parameters.KafkaSecurityConfigurer.withOAuthScope(String scope) Sets the OAuth scope.KafkaSecurityConfigurer.withSsl(boolean useSsl) Enables or disables SSL encryption.