Class SslBundleSslEngineFactory

java.lang.Object

org.springframework.boot.kafka.autoconfigure.SslBundleSslEngineFactory

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.security.auth.SslEngineFactory

public class SslBundleSslEngineFactory
extends Object
implements org.apache.kafka.common.security.auth.SslEngineFactory

An SslEngineFactory that configures creates an SSLEngine from an SslBundle.

Since:

4.0.0

Author:

Andy Wilkinson, Scott Frederick

Constructor Summary

Constructors

Constructor	Description
SslBundleSslEngineFactory()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
SSLEngine	createClientSslEngine(String peerHost, int peerPort, String endpointIdentification)
SSLEngine	createServerSslEngine(String peerHost, int peerPort)
@Nullable KeyStore	keystore()
Set<String>	reconfigurableConfigs()
boolean	shouldBeRebuilt(Map<String,Object> nextConfigs)
@Nullable KeyStore	truststore()

Methods inherited from class Object

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

Constructor Details

SslBundleSslEngineFactory

public SslBundleSslEngineFactory()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

createClientSslEngine

public SSLEngine createClientSslEngine(String peerHost,
 int peerPort,
 String endpointIdentification)

Specified by:

createClientSslEngine in interface org.apache.kafka.common.security.auth.SslEngineFactory

createServerSslEngine

public SSLEngine createServerSslEngine(String peerHost,
 int peerPort)

Specified by:

createServerSslEngine in interface org.apache.kafka.common.security.auth.SslEngineFactory

shouldBeRebuilt

public boolean shouldBeRebuilt(Map<String,Object> nextConfigs)

Specified by:

shouldBeRebuilt in interface org.apache.kafka.common.security.auth.SslEngineFactory

reconfigurableConfigs

public Set<String> reconfigurableConfigs()

Specified by:

reconfigurableConfigs in interface org.apache.kafka.common.security.auth.SslEngineFactory

keystore

public @Nullable KeyStore keystore()

Specified by:

keystore in interface org.apache.kafka.common.security.auth.SslEngineFactory

truststore

public @Nullable KeyStore truststore()

Specified by:

truststore in interface org.apache.kafka.common.security.auth.SslEngineFactory