@ConfigurationProperties(prefix="spring.kafka") public class KafkaProperties extends ObjectSE
これらのプロパティの詳細については、Kafka のドキュメントを参照してください。
修飾子と型 | クラスと説明 |
---|---|
static class | KafkaProperties.Admin |
static class | KafkaProperties.Cleanup |
static class | KafkaProperties.Consumer |
static class | KafkaProperties.IsolationLevel |
static class | KafkaProperties.Jaas |
static class | KafkaProperties.Listener |
static class | KafkaProperties.Producer |
static class | KafkaProperties.Security |
static class | KafkaProperties.Ssl |
static class | KafkaProperties.Streams 優先度の高い(および中程度の)Streams プロパティと一般的なプロパティバケット。 |
static class | KafkaProperties.Template |
コンストラクターと説明 |
---|
KafkaProperties() |
修飾子と型 | メソッドと説明 |
---|---|
MapSE<StringSE, ObjectSE> | buildAdminProperties() このインスタンスの状態から管理プロパティの初期マップを作成します。 |
MapSE<StringSE, ObjectSE> | buildConsumerProperties() このインスタンスの状態からコンシューマープロパティの初期マップを作成します。 |
MapSE<StringSE, ObjectSE> | buildProducerProperties() このインスタンスの状態からプロデューサープロパティの初期マップを作成します。 |
MapSE<StringSE, ObjectSE> | buildStreamsProperties() このインスタンスの状態からストリームプロパティの初期マップを作成します。 |
KafkaProperties.Admin | getAdmin() |
ListSE<StringSE> | getBootstrapServers() |
StringSE | getClientId() |
KafkaProperties.Consumer | getConsumer() |
KafkaProperties.Jaas | getJaas() |
KafkaProperties.Listener | getListener() |
KafkaProperties.Producer | getProducer() |
MapSE<StringSE, StringSE> | getProperties() |
KafkaProperties.Security | getSecurity() |
KafkaProperties.Ssl | getSsl() |
KafkaProperties.Streams | getStreams() |
KafkaProperties.Template | getTemplate() |
void | setBootstrapServers(ListSE<StringSE> bootstrapServers) |
void | setClientId(StringSE clientId) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public StringSE getClientId()
public void setClientId(StringSE clientId)
public KafkaProperties.Consumer getConsumer()
public KafkaProperties.Producer getProducer()
public KafkaProperties.Listener getListener()
public KafkaProperties.Admin getAdmin()
public KafkaProperties.Streams getStreams()
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Jaas getJaas()
public KafkaProperties.Template getTemplate()
public KafkaProperties.Security getSecurity()
public MapSE<StringSE,ObjectSE> buildConsumerProperties()
これにより、必要に応じて追加のプロパティを追加し、デフォルトの kafkaConsumerFactory Bean をオーバーライドできます。
public MapSE<StringSE,ObjectSE> buildProducerProperties()
これにより、必要に応じてプロパティを追加し、デフォルトの kafkaProducerFactory Bean をオーバーライドできます。
public MapSE<StringSE,ObjectSE> buildAdminProperties()
これにより、必要に応じて追加のプロパティを追加し、デフォルトの kafkaAdmin Bean を上書きできます。