You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zipkin.apache.org by ad...@apache.org on 2019/05/16 19:32:00 UTC
[incubator-zipkin-brave] branch master updated: rename test helper
method (#910)
This is an automated email from the ASF dual-hosted git repository.
adriancole pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-zipkin-brave.git
The following commit(s) were added to refs/heads/master by this push:
new 5398599 rename test helper method (#910)
5398599 is described below
commit 5398599dd8d327dd48a1d86821dea3953fb5d438
Author: Jorg Heymans <jo...@gmail.com>
AuthorDate: Thu May 16 21:31:56 2019 +0200
rename test helper method (#910)
---
.../brave/kafka/streams/ITKafkaStreamsTracing.java | 46 +++++++++++-----------
1 file changed, 23 insertions(+), 23 deletions(-)
diff --git a/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java b/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
index 8a902fc..c5d412b 100644
--- a/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
+++ b/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
@@ -100,7 +100,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -126,7 +126,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams =
new KafkaStreams(topology, streamsProperties(), kafkaStreamsTracing.kafkaClientSupplier());
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -150,7 +150,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
consumer = createTracingConsumer(outputTopic);
@@ -194,7 +194,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -222,7 +222,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -253,7 +253,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -283,7 +283,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -313,7 +313,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -353,7 +353,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -383,7 +383,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -416,7 +416,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -457,7 +457,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -510,7 +510,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -567,7 +567,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -628,7 +628,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -681,7 +681,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -718,7 +718,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -755,7 +755,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -792,7 +792,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -849,7 +849,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -902,7 +902,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreams(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -959,7 +959,7 @@ public class ITKafkaStreamsTracing {
KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
- producer = createTracingProducer();
+ producer = createProducer();
producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
waitForStreamToRun(streams);
@@ -1002,7 +1002,7 @@ public class ITKafkaStreamsTracing {
return new KafkaStreams(topology, properties);
}
- Producer<String, String> createTracingProducer() {
+ Producer<String, String> createProducer() {
return kafka.helper().createStringProducer();
}