Package com.norconex.committer.apachekafka

Class ApacheKafkaCommitterConfig

java.lang.Object
com.norconex.committer.core.BaseCommitterConfig
com.norconex.committer.core.batch.BaseBatchCommitterConfig
com.norconex.committer.apachekafka.ApacheKafkaCommitterConfig
public class ApacheKafkaCommitterConfig extends BaseBatchCommitterConfig

Configuration for ApacheKafkaCommitter.

Author:
Harinder Hanjan

  • Constructor Details

    • ApacheKafkaCommitterConfig

      public ApacheKafkaCommitterConfig()

  • Method Details

    • getTopicName

      public String getTopicName()
      The topic name to which documents will be sent

    • getBootstrapServers

      public String getBootstrapServers()
      The Apache Kafka broker list, comma-separated (e.g., host1:port1,host2:port2,...).

    • isCreateTopic

      public boolean isCreateTopic()
      Whether to create the topic in Apache Kafka. It will be created only if it is not already present.

    • getPartitions

      public int getPartitions()
      The number of partitions for the new topic. Required if isCreateTopic() is true

    • getReplicationFactor

      public short getReplicationFactor()
      Gets the replication factor for the new topic. Required if isCreateTopic() is true

    • setTopicName

      public ApacheKafkaCommitterConfig setTopicName(String topicName)
      The topic name to which documents will be sent
      Returns:
      this.

    • setBootstrapServers

      public ApacheKafkaCommitterConfig setBootstrapServers(String bootstrapServers)
      The Apache Kafka broker list, comma-separated (e.g., host1:port1,host2:port2,...).
      Returns:
      this.

    • setCreateTopic

      public ApacheKafkaCommitterConfig setCreateTopic(boolean createTopic)
      Whether to create the topic in Apache Kafka. It will be created only if it is not already present.
      Returns:
      this.

    • setPartitions

      public ApacheKafkaCommitterConfig setPartitions(int partitions)
      The number of partitions for the new topic. Required if isCreateTopic() is true
      Returns:
      this.

    • setReplicationFactor

      public ApacheKafkaCommitterConfig setReplicationFactor(short replicationFactor)
      Gets the replication factor for the new topic. Required if isCreateTopic() is true
      Returns:
      this.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class BaseBatchCommitterConfig

    • canEqual

      protected boolean canEqual(Object other)
      Overrides:
      canEqual in class BaseBatchCommitterConfig

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class BaseBatchCommitterConfig

    • toString

      public String toString()
      Overrides:
      toString in class BaseBatchCommitterConfig