protected org.springframework.messaging.MessageHandler |
KafkaMessageChannelBinder.createProducerMessageHandler(ProducerDestination destination,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
protected org.springframework.messaging.MessageHandler |
KafkaMessageChannelBinder.createProducerMessageHandler(ProducerDestination destination,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel channel,
org.springframework.messaging.MessageChannel errorChannel) |
protected org.springframework.kafka.core.DefaultKafkaProducerFactory<byte[],byte[]> |
KafkaMessageChannelBinder.getProducerFactory(String transactionIdPrefix,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties) |
protected boolean |
KafkaMessageChannelBinder.useNativeEncoding(ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties) |