Class VertxKafkaConfigurationOptionsProxy
- java.lang.Object
-
- org.apache.camel.component.vertx.kafka.VertxKafkaConfigurationOptionsProxy
-
public class VertxKafkaConfigurationOptionsProxy extends Object
-
-
Constructor Summary
Constructors Constructor Description VertxKafkaConfigurationOptionsProxy(VertxKafkaConfiguration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description VertxKafkaConfiguration
getConfiguration()
String
getKeySerializer(org.apache.camel.Message message)
Object
getMessageKey(org.apache.camel.Message message)
String
getOverrideTopic(org.apache.camel.Message message)
Integer
getPartitionId(org.apache.camel.Message message)
String
getTopic(org.apache.camel.Message message)
String
getValueSerializer(org.apache.camel.Message message)
-
-
-
Constructor Detail
-
VertxKafkaConfigurationOptionsProxy
public VertxKafkaConfigurationOptionsProxy(VertxKafkaConfiguration configuration)
-
-
Method Detail
-
getPartitionId
public Integer getPartitionId(org.apache.camel.Message message)
-
getMessageKey
public Object getMessageKey(org.apache.camel.Message message)
-
getKeySerializer
public String getKeySerializer(org.apache.camel.Message message)
-
getValueSerializer
public String getValueSerializer(org.apache.camel.Message message)
-
getTopic
public String getTopic(org.apache.camel.Message message)
-
getOverrideTopic
public String getOverrideTopic(org.apache.camel.Message message)
-
getConfiguration
public VertxKafkaConfiguration getConfiguration()
-
-