Class ConsumerConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.oracle.okafka.clients.consumer.ConsumerConfig

public class ConsumerConfig extends org.apache.kafka.common.config.AbstractConfig
The consumer configuration keys
  • Field Details

  • Constructor Details

    • ConsumerConfig

      public ConsumerConfig(Properties props)
    • ConsumerConfig

      public ConsumerConfig(Map<String,Object> props)
    • ConsumerConfig

      protected ConsumerConfig(Map<?,?> props, boolean doLog)
  • Method Details

    • postProcessParsedConfig

      protected Map<String,Object> postProcessParsedConfig(Map<String,Object> parsedValues)
      Overrides:
      postProcessParsedConfig in class org.apache.kafka.common.config.AbstractConfig
    • addDeserializerToConfig

      @Deprecated public static Map<String,Object> addDeserializerToConfig(Map<String,Object> configs, org.apache.kafka.common.serialization.Deserializer<?> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<?> valueDeserializer)
      Deprecated.
      Since 2.7.0. This will be removed in a future major release.
    • addDeserializerToConfig

      @Deprecated public static Properties addDeserializerToConfig(Properties properties, org.apache.kafka.common.serialization.Deserializer<?> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<?> valueDeserializer)
      Deprecated.
      Since 2.7.0. This will be removed in a future major release.
    • configNames

      public static Set<String> configNames()
    • configDef

      public static org.apache.kafka.common.config.ConfigDef configDef()
    • main

      public static void main(String[] args)