diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/exception/KafkaAdapterUnsupportedOpException.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/exception/KafkaAdapterUnsupportedOpException.java index 4386ddcd6..cb39d0cd4 100644 --- a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/exception/KafkaAdapterUnsupportedOpException.java +++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/exception/KafkaAdapterUnsupportedOpException.java @@ -19,7 +19,7 @@ package io.nosqlbench.adapter.kafka.exception; public class KafkaAdapterUnsupportedOpException extends RuntimeException { - public KafkaAdapterUnsupportedOpException(String pulsarOpType) { - super("Unsupported Pulsar adapter operation type: \"" + pulsarOpType + "\""); + public KafkaAdapterUnsupportedOpException(String kafkaOpType) { + super("Unsupported Kafka adapter operation type: \"" + kafkaOpType + "\""); } } diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/util/KafkaClientConf.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/util/KafkaClientConf.java index 0d1b82f2d..bdb9d229a 100644 --- a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/util/KafkaClientConf.java +++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/util/KafkaClientConf.java @@ -49,7 +49,7 @@ public class KafkaClientConf { public KafkaClientConf(String clientConfFileName) { ////////////////// - // Read related Pulsar client configuration settings from a file + // Read related Kafka client configuration settings from a file readRawConfFromFile(clientConfFileName); diff --git a/adapter-kafka/src/main/resources/README.md b/adapter-kafka/src/main/resources/README.md index e01f35fd0..0cdb49b53 100644 --- a/adapter-kafka/src/main/resources/README.md +++ b/adapter-kafka/src/main/resources/README.md @@ -1,10 +1,10 @@ # Overview -This NB Kafka driver allows publishing messages to or consuming messages from +This NB Kafka adapter allows publishing messages to or consuming messages from * a Kafka cluster, or * a Pulsar cluster with [S4K](https://github.com/datastax/starlight-for-kafka) or [KoP](https://github.com/streamnative/kop) Kafka Protocol handler for Pulsar. -At high level, this driver supports the following Kafka functionalities +At high level, this adapter supports the following Kafka functionalities * Publishing messages to one Kafka topic with sync. or async. message-send acknowledgements (from brokers) * Subscribing messages from one or multiple Kafka topics with sync. or async. message-recv acknowlegements (to brokers) (aka, message commits) * auto message commit @@ -26,7 +26,7 @@ $ run driver=kafka -vv cycles=100 threads=2 num_clnt=2 yaml=kafka_produ $ run driver=kafka -vv cycles=100 threads=4 num_clnt=2 num_cons_grp=2 yaml=kafka_producer.yaml config=kafka_config.properties bootstrap_server=PLAINTEXT://localhost:9092 ``` -## NB Kafka driver specific CLI parameters +## NB Kafka adapter specific CLI parameters * `num_clnt`: the number of Kafka clients to publish messages to or to receive messages from * For producer workload, this is the number of the producer threads to publish messages to the same topic