Class KafkaLogConfig

java.lang.Object
org.nuxeo.lib.stream.log.AbstractLogConfig
org.nuxeo.lib.stream.log.kafka.KafkaLogConfig
All Implemented Interfaces:
LogConfig

public class KafkaLogConfig extends AbstractLogConfig
Since:
11.1
  • Field Details

    • DISABLE_SUBSCRIBE_PROP

      public static final String DISABLE_SUBSCRIBE_PROP
      See Also:
    • DEFAULT_REPLICATION_FACTOR_PROP

      public static final String DEFAULT_REPLICATION_FACTOR_PROP
      See Also:
    • adminProperties

      protected final Properties adminProperties
    • producerProperties

      protected final Properties producerProperties
    • consumerProperties

      protected final Properties consumerProperties
    • defaultReplicationFactor

      protected final short defaultReplicationFactor
    • disableSubscribe

      protected final Boolean disableSubscribe
    • resolver

      protected final NameResolver resolver
    • name

      protected final String name
  • Constructor Details

  • Method Details

    • getReplicatorFactor

      public short getReplicatorFactor()
    • getDisableSubscribe

      public Boolean getDisableSubscribe()
    • getResolver

      public NameResolver getResolver()
    • getAdminProperties

      public Properties getAdminProperties()
    • getProducerProperties

      public Properties getProducerProperties()
    • getConsumerProperties

      public Properties getConsumerProperties()
    • normalizeAdminProperties

      protected Properties normalizeAdminProperties(Properties adminProperties)
    • normalizeProducerProperties

      protected Properties normalizeProducerProperties(Properties producerProperties)
    • normalizeConsumerProperties

      protected Properties normalizeConsumerProperties(Properties consumerProperties)
    • createAdminProperties

      protected Properties createAdminProperties(Properties producerProperties)
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • filterDisplayedProperties

      protected String filterDisplayedProperties(Properties properties)