#332 fix Generator creation

sngular · Jan 26, 2024 · 25b7a0d · 25b7a0d
1 parent c8de4d0
commit 25b7a0d
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java b/src/main/java/com/sngular/kloadgen/sampler/KafkaProducerSampler.java
@@ -69,11 +69,7 @@ public final class KafkaProducerSampler extends AbstractJavaSamplerClient implem
   public void setupTest(final JavaSamplerContext context) {
     props = JMeterContextService.getContext().getProperties();
 
-    if (context.getJMeterVariables().get(PropsKeysHelper.VALUE_SCHEMA) == null) {
-      generator = SamplerUtil.configureKeyGenerator(props);
-    } else {
-      generator = SamplerUtil.configureValueGenerator(props);
-    }
+    generator = SamplerUtil.configureValueGenerator(props);
 
     if ("true".equals(context.getJMeterVariables().get(PropsKeysHelper.SCHEMA_KEYED_MESSAGE_KEY))
         || "true".equals(context.getJMeterVariables().get(PropsKeysHelper.SIMPLE_KEYED_MESSAGE_KEY))) {