IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix typos

Browse Source
This commit is contained in:
Massimiliano Mirelli 2023-03-07 14:12:28 +02:00
parent 7da1973f52
commit e7730ae281
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/exception/KafkaAdapterUnsupportedOpException.java
View File

@ -19,7 +19,7 @@ package io.nosqlbench.adapter.kafka.exception;
public class KafkaAdapterUnsupportedOpException extends RuntimeException { public class KafkaAdapterUnsupportedOpException extends RuntimeException {
public KafkaAdapterUnsupportedOpException(String pulsarOpType) { public KafkaAdapterUnsupportedOpException(String kafkaOpType) {
super("Unsupported Pulsar adapter operation type: \"" + pulsarOpType + "\""); super("Unsupported Kafka adapter operation type: \"" + kafkaOpType + "\"");
} }
} }

2
adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/util/KafkaClientConf.java
View File

@ -49,7 +49,7 @@ public class KafkaClientConf {
public KafkaClientConf(String clientConfFileName) { public KafkaClientConf(String clientConfFileName) {
////////////////// //////////////////
// Read related Pulsar client configuration settings from a file // Read related Kafka client configuration settings from a file
readRawConfFromFile(clientConfFileName); readRawConfFromFile(clientConfFileName);

6
adapter-kafka/src/main/resources/README.md
View File

@ -1,10 +1,10 @@
# Overview # 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 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. * 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) * 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) * Subscribing messages from one or multiple Kafka topics with sync. or async. message-recv acknowlegements (to brokers) (aka, message commits)
* auto message commit * auto message commit
@ -26,7 +26,7 @@ $ <nb_cmd> run driver=kafka -vv cycles=100 threads=2 num_clnt=2 yaml=kafka_produ
$ <nb_cmd> 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_cmd> 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 * `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 * For producer workload, this is the number of the producer threads to publish messages to the same topic