381 issue schema registry url field not recognized when running kafka…

… producer with apicurio (#383)

* #381 Minor Change When Use Apicurio Dont Set The Property

Apparently when you pass the properties to the kafkaProducer this cant map the apicurio.schema.url so its need another property for that purpose

* #381 Removed Unused Property From Kafka Producer Sampler

* #381 Upgrade Pom Version

pom-maven-central.xml

@@ -7,7 +7,7 @@
 
  <artifactId>kloadgen</artifactId>
 
- <version>5.6.2</version>
+ <version>5.6.3</version>
 
  <name>KLoadGen</name>
  <description>Load Generation Jmeter plugin for Kafka Cluster. Supporting AVRO, JSON Schema and Protobuf schema types. Generate Artificial

pom.xml

@@ -7,7 +7,7 @@
 
  <artifactId>kloadgen</artifactId>
 
- <version>5.6.2</version>
+ <version>5.6.3</version>
 
  <name>KLoadGen</name>
  <description>Load Generation Jmeter plugin for Kafka Cluster. Supporting AVRO, JSON Schema and Protobuf schema types. Generate Artificial

src/main/java/com/sngular/kloadgen/sampler/SamplerUtil.java

@@ -92,8 +92,6 @@ public static Arguments getCommonDefaultParameters() {
  defaultParameters.addArgument(SslConfigs.SSL_PROVIDER_CONFIG, "");
  defaultParameters.addArgument(SslConfigs.SSL_PROTOCOL_CONFIG, SslConfigs.DEFAULT_SSL_PROTOCOL);
  defaultParameters.addArgument(SchemaRegistryKeyHelper.ENABLE_AUTO_SCHEMA_REGISTRATION_CONFIG, ProducerKeysHelper.ENABLE_AUTO_SCHEMA_REGISTRATION_CONFIG_DEFAULT);
- defaultParameters.addArgument(SchemaRegistryKeyHelper.SCHEMA_REGISTRY_URL, "");
-
  return defaultParameters;
  }
 
@@ -133,9 +131,10 @@ public static Properties setupCommonProperties(final JavaSamplerContext context)
  if (SchemaRegistryKeyHelper.SCHEMA_REGISTRY_APICURIO.equalsIgnoreCase(schemaRegistryNameValue)) {
  props.put(SerdeConfig.AUTO_REGISTER_ARTIFACT, enableSchemaRegistrationValue);
  props.put(SchemaResolverConfig.REGISTRY_URL, context.getJMeterVariables().get(SchemaResolverConfig.REGISTRY_URL));
+ props.put(SchemaRegistryKeyHelper.SCHEMA_REGISTRY_URL, context.getJMeterVariables().get(SchemaResolverConfig.REGISTRY_URL));
  } else {
  props.put(SchemaRegistryKeyHelper.ENABLE_AUTO_SCHEMA_REGISTRATION_CONFIG, enableSchemaRegistrationValue);
- String schemaRegistryURL = context.getJMeterVariables().get(SchemaRegistryKeyHelper.SCHEMA_REGISTRY_URL);
+ final String schemaRegistryURL = context.getJMeterVariables().get(SchemaRegistryKeyHelper.SCHEMA_REGISTRY_URL);
  if (StringUtils.isNotBlank(schemaRegistryURL)) {
  props.put(SchemaRegistryKeyHelper.SCHEMA_REGISTRY_URL, schemaRegistryURL);
  }