-
Notifications
You must be signed in to change notification settings - Fork 60
Description
sudo bin/benchmark --drivers kafka/kafka-exactly-once.yaml --workers 10.0.100.195:9092,10.0.100.97:9092,10.0.101.68:

9092 workloads/1-topic-16-partitions-1kb.yaml
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/home/sanjay/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.13.3/log4j-slf4j-impl-2.13.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/sanjay/.m2/repository/ch/qos/logback/logback-classic/1.0.13/logback-classic-1.0.13.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
19:09:12.208 [main] INFO - Starting benchmark with config: {
"drivers" : [ "kafka/kafka-exactly-once.yaml" ],
"workers" : [ "http://10.0.100.195:9092", "http://10.0.100.97:9092", "http://10.0.101.68:9092" ],
"workersFile" : null,
"workloads" : [ "workloads/1-topic-16-partitions-1kb.yaml" ],
"output" : null
}
19:09:12.234 [main] INFO - Workloads: {
"1-topic-16-partitions-1kb" : {
"name" : "1 producer / 1 consumers on 1 topic",
"topics" : 1,
"partitionsPerTopic" : 16,
"keyDistributor" : "NO_KEY",
"messageSize" : 1024,
"payloadFile" : "payload/payload-1Kb.data",
"subscriptionsPerTopic" : 1,
"producersPerTopic" : 1,
"consumerPerSubscription" : 1,
"producerRate" : 50000,
"consumerBacklogSizeGB" : 0,
"testDurationMinutes" : 15,
"consumerOnly" : false
}
}
19:09:12.239 [main] INFO - Workers list - producers: [http://10.0.100.195:9092]
19:09:12.239 [main] INFO - Workers list - consumers: [http://10.0.100.97:9092]
19:09:12.432 [main] ERROR - Failed to run the workload '1 producer / 1 consumers on 1 topic' for driver 'kafka/kafka-exactly-once.yaml'
java.io.FileNotFoundException: kafka/kafka-exactly-once.yaml (No such file or directory)
at java.io.FileInputStream.open0(Native Method) ~[?:?]
at java.io.FileInputStream.open(FileInputStream.java:216) ~[?:?]
at java.io.FileInputStream.(FileInputStream.java:157) ~[?:?]
at com.fasterxml.jackson.dataformat.yaml.YAMLFactory.createParser(YAMLFactory.java:307) ~[jackson-dataformat-yaml-2.9.3.jar:2.9.3]
at com.fasterxml.jackson.dataformat.yaml.YAMLFactory.createParser(YAMLFactory.java:14) ~[jackson-dataformat-yaml-2.9.3.jar:2.9.3]
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2903) ~[jackson-databind-2.9.10.5.jar:2.9.10.5]
at io.openmessaging.benchmark.Benchmark.lambda$main$0(Benchmark.java:141) ~[classes/:?]
at java.util.ArrayList.forEach(ArrayList.java:1511) ~[?:?]
at io.openmessaging.benchmark.Benchmark.lambda$main$1(Benchmark.java:138) ~[classes/:?]
at java.util.TreeMap.forEach(TreeMap.java:1282) [?:?]
Pls suggest me where i was wrong here in conducting performance test for kafka