Class VertxKafkaConfigurationOptionsProxy


  • public class VertxKafkaConfigurationOptionsProxy
    extends Object
    • 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)