Uses of Class
com.norconex.committer.apachekafka.ApacheKafkaCommitterConfig
Packages that use ApacheKafkaCommitterConfig
-
Uses of ApacheKafkaCommitterConfig in com.norconex.committer.apachekafka
Methods in com.norconex.committer.apachekafka that return ApacheKafkaCommitterConfigModifier and TypeMethodDescriptionApacheKafkaCommitter.getConfiguration()ApacheKafkaCommitterConfig.setBootstrapServers(String bootstrapServers) The Apache Kafka broker list, comma-separated (e.g., host1:port1,host2:port2,...).ApacheKafkaCommitterConfig.setCreateTopic(boolean createTopic) Whether to create the topic in Apache Kafka.ApacheKafkaCommitterConfig.setPartitions(int partitions) The number of partitions for the new topic.ApacheKafkaCommitterConfig.setReplicationFactor(short replicationFactor) Gets the replication factor for the new topic.ApacheKafkaCommitterConfig.setTopicName(String topicName) The topic name to which documents will be sent