diff --git a/driver-kop/pulsar_to_kafka.yaml b/driver-kop/pulsar_to_kafka.yaml
index d587395c3..6fcd315e6 100644
--- a/driver-kop/pulsar_to_kafka.yaml
+++ b/driver-kop/pulsar_to_kafka.yaml
@@ -12,7 +12,7 @@
 # limitations under the License.
 #
 
-name: Kafka producer and Pulsar consumer
+name: Pulsar producer and Kafka consumer
 driverClass: io.openmessaging.benchmark.driver.kop.KopBenchmarkDriver
 
 producerType: pulsar
diff --git a/driver-kop/src/main/java/io/openmessaging/benchmark/driver/kop/KopBenchmarkDriver.java b/driver-kop/src/main/java/io/openmessaging/benchmark/driver/kop/KopBenchmarkDriver.java
index 32ccb6ba2..7a08566a7 100644
--- a/driver-kop/src/main/java/io/openmessaging/benchmark/driver/kop/KopBenchmarkDriver.java
+++ b/driver-kop/src/main/java/io/openmessaging/benchmark/driver/kop/KopBenchmarkDriver.java
@@ -153,7 +153,7 @@ public CompletableFuture<BenchmarkProducer> createProducer(String topic) {
                     new KafkaBenchmarkProducer(new KafkaProducer<>(producerProperties), topic);
             producers.add(producer);
             return CompletableFuture.completedFuture(producer);
-        } else if (config.consumerType.equals(ClientType.PULSAR)) {
+        } else if (config.producerType.equals(ClientType.PULSAR)) {
             return producerBuilder
                     .clone()
                     .topic(topic)