Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing - PR Comments

Browse Source
This commit is contained in:
Gary Russell
2017-10-20 14:45:55 -04:00
committed by Artem Bilan
parent b65f59cd67
commit 0580252f7a
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaProducerMessageHandlerSpec.java
View File

@@ -31,7 +31,6 @@ import org.springframework.integration.expression.ValueExpression;
import org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.support.DefaultKafkaHeaderMapper;
import org.springframework.kafka.support.KafkaHeaderMapper;
import org.springframework.kafka.support.LoggingProducerListener;
import org.springframework.kafka.support.ProducerListener;
@@ -259,14 +258,6 @@ public class KafkaProducerMessageHandlerSpec<K, V, S extends KafkaProducerMessag
return _this();
}
/**
* Add a default header mapper to map spring messaging headers to Kafka headers.
* @return the spec.
*/
public S headerMapper() {
return headerMapper(new DefaultKafkaHeaderMapper());
}
/**
* Specify a header mapper to map spring messaging headers to Kafka headers.
* @param mapper the mapper.