minor cleanup

Author: sbcd90

src/test/scala/io/gatling/misc/KafkaAvroConsumer.scala

@@ -11,10 +11,10 @@ import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord, Consum
 import scala.collection.JavaConversions._
 
 object KafkaAvroConsumer extends App {
-  val kafkaTopic = "kafka_streams_testing998"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
-  val schemaRegistryUrl = "http://10.97.181.169:8081"
+  val schemaRegistryUrl = "http://localhost:8081"
   val VALUE_SERIALIZATION_FLAG = "value"
 
   val props = new util.HashMap[String, Object]()

src/test/scala/io/gatling/misc/SimpleKafkaConsumer.scala

@@ -6,8 +6,8 @@ import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord, Consum
 import org.apache.kafka.common.serialization.StringDeserializer
 
 object SimpleKafkaConsumer extends App {
-  val kafkaTopic = "kafka_streams_testing698"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)

src/test/scala/io/gatling/simulation/BasicSimulation.scala

@@ -10,8 +10,8 @@ import org.apache.kafka.clients.producer.ProducerConfig
 import org.apache.kafka.common.serialization.StringSerializer
 
 class BasicSimulation extends Simulation {
-  val kafkaTopic = "kafka_streams_testing698"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)

src/test/scala/io/gatling/simulation/ByteArraySimulation.scala

@@ -10,8 +10,8 @@ import org.apache.kafka.clients.producer.ProducerConfig
 import org.apache.kafka.common.serialization.ByteArraySerializer
 
 class ByteArraySimulation extends Simulation {
-  val kafkaTopic = "kafka_streams_testing798"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)

src/test/scala/io/gatling/simulation/FeederByteArraySimulation.scala

@@ -4,14 +4,13 @@ import java.util
 
 import io.gatling.core.Predef._
 import io.gatling.core.Predef.Simulation
-import io.gatling.data.generator.RandomDataGenerator
 import io.gatling.kafka.{KafkaProducerBuilder, KafkaProducerProtocol}
 import org.apache.kafka.clients.producer.ProducerConfig
 import org.apache.kafka.common.serialization.ByteArraySerializer
 
 class FeederByteArraySimulation extends Simulation {
-  val kafkaTopic = "kafka_streams_testing898"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)

src/test/scala/io/gatling/simulation/FeederSimulationWithAvroSchema.scala

@@ -10,14 +10,14 @@ import org.apache.avro.generic.GenericRecord
 import org.apache.kafka.clients.producer.ProducerConfig
 
 class FeederSimulationWithAvroSchema extends Simulation {
-  val kafkaTopic = "kafka_streams_testing998"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)
   props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[KafkaAvroSerializer])
   props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[KafkaAvroSerializer])
-  props.put("schema.registry.url", "http://10.97.181.169:8081")
+  props.put("schema.registry.url", "http://locahost:8081")
 
   val kafkaProducerProtocol =
     new KafkaProducerProtocol[GenericRecord, GenericRecord](props, kafkaTopic)

src/test/scala/io/gatling/simulation/SimulationWithAvroSchema.scala

@@ -11,14 +11,14 @@ import org.apache.avro.generic.GenericRecord
 import org.apache.kafka.clients.producer.ProducerConfig
 
 class SimulationWithAvroSchema extends Simulation {
-  val kafkaTopic = "kafka_streams_testing398"
-  val kafkaBrokers = "10.97.181.169:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)
   props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[KafkaAvroSerializer])
   props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[KafkaAvroSerializer])
-  props.put("schema.registry.url", "http://10.97.181.169:8081")
+  props.put("schema.registry.url", "http://localhost:8081")
 
   val user_schema =
     s"""

src/test/scala/io/gatling/simulation/SimulationWithCustomData.scala

@@ -11,8 +11,8 @@ import org.apache.kafka.common.serialization.IntegerSerializer
 import scala.concurrent.duration._
 
 class SimulationWithCustomData extends Simulation {
-  val kafkaTopic = "kafka_streams_testing698"
-  val kafkaBrokers = "10.97.183.115:9092,10.97.191.51:9092,10.97.152.59:9092,10.97.152.66:9092"
+  val kafkaTopic = "test_topic"
+  val kafkaBrokers = "localhost:9092"
 
   val props = new util.HashMap[String, Object]()
   props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokers)