K - 鍵の型。V - 送信値型。R - 応答値の型。S - KafkaProducerMessageHandlerSpec 拡張型。public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> extends KafkaProducerMessageHandlerSpec<K,V,S>
KafkaProducerMessageHandler の MessageHandlerSpec 実装。| 修飾子と型 | クラスと説明 |
|---|---|
static class | KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K, V, R>KafkaTemplate ベースの KafkaProducerMessageHandlerSpec 拡張。 |
static class | KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>KafkaTemplate の IntegrationComponentSpec 実装。 |
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K, V>PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子と型 | メソッドと説明 |
|---|---|
S | replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) 返信用のメッセージコンバーターを設定します（ゲートウェイの場合）。 |
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
messageConverter - コンバーター。