public static class CamelKafkaRouteBuilder.Builder
extends java.lang.Object
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
CamelKafkaRouteBuilder |
build() |
CamelKafkaRouteBuilder.Builder |
camelContext(org.apache.camel.CamelContext camelContext) |
CamelKafkaRouteBuilder.Builder |
dataTypeUnMarshal(java.lang.String dataTypeUnMarshal) |
CamelKafkaRouteBuilder.Builder |
datavecMarshaller(java.lang.String datavecMarshaller) |
CamelKafkaRouteBuilder.Builder |
inputFormat(java.lang.String inputFormat) |
CamelKafkaRouteBuilder.Builder |
inputUri(java.lang.String inputUri) |
CamelKafkaRouteBuilder.Builder |
kafkaBrokerList(java.lang.String kafkaBrokerList) |
CamelKafkaRouteBuilder.Builder |
processor(org.apache.camel.Processor processor) |
CamelKafkaRouteBuilder.Builder |
topicName(java.lang.String topicName) |
CamelKafkaRouteBuilder.Builder |
writableConverter(java.lang.String writableConverter) |
CamelKafkaRouteBuilder.Builder |
zooKeeperHost(java.lang.String zooKeeperHost) |
CamelKafkaRouteBuilder.Builder |
zooKeeperPort(int zooKeeperPort) |
public CamelKafkaRouteBuilder.Builder zooKeeperHost(java.lang.String zooKeeperHost)
public CamelKafkaRouteBuilder.Builder zooKeeperPort(int zooKeeperPort)
public CamelKafkaRouteBuilder.Builder processor(org.apache.camel.Processor processor)
public CamelKafkaRouteBuilder.Builder kafkaBrokerList(java.lang.String kafkaBrokerList)
public CamelKafkaRouteBuilder.Builder inputFormat(java.lang.String inputFormat)
public CamelKafkaRouteBuilder.Builder camelContext(org.apache.camel.CamelContext camelContext)
public CamelKafkaRouteBuilder.Builder inputUri(java.lang.String inputUri)
public CamelKafkaRouteBuilder.Builder writableConverter(java.lang.String writableConverter)
public CamelKafkaRouteBuilder.Builder datavecMarshaller(java.lang.String datavecMarshaller)
public CamelKafkaRouteBuilder.Builder dataTypeUnMarshal(java.lang.String dataTypeUnMarshal)
public CamelKafkaRouteBuilder.Builder topicName(java.lang.String topicName)
public CamelKafkaRouteBuilder build()