Code

Kafka Streams helper operations#833

Code

Merged

codefromthecrypt merged 19 commits intoopenzipkin:masteropenzipkin/brave:masterfrom jeqo:kafka-streams-wrapperCopy head branch name to clipboardDec 11, 2018

+436-42

Commits

Commits on Nov 25, 2018

• feat: map, mapValues, foreach

  jeqo

  committed
  30e01aa

  Copy full SHA for 30e01aa

• feat: peek and mark

  jeqo

  committed
  c61c656

  Copy full SHA for c61c656

• feat: testing kstream methods

  jeqo

  committed
  5909158

  Copy full SHA for 5909158

• feat: add annotation to test

  jeqo

  committed
  2a4a41d

  Copy full SHA for 2a4a41d

Commits on Nov 26, 2018

• refactor: peek and mark from processor to transformer

  jeqo

  committed
  cfb7915

  Copy full SHA for cfb7915

• docs: add javadocs to new methods

  jeqo

  committed
  371e97b

  Copy full SHA for 371e97b

Commits on Nov 27, 2018

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for c37a359
  

  adriancole

  and

  jeqo

  authored
  c37a359

  Copy full SHA for c37a359

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for fad5ba1
  

  adriancole

  and

  jeqo

  authored
  fad5ba1

  Copy full SHA for fad5ba1

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 493df93
  

  adriancole

  and

  jeqo

  authored
  493df93

  Copy full SHA for 493df93

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 1f8b894
  

  adriancole

  and

  jeqo

  authored
  1f8b894

  Copy full SHA for 1f8b894

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 9d9ff72
  

  adriancole

  and

  jeqo

  authored
  9d9ff72

  Copy full SHA for 9d9ff72

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for a745f12
  

  ImFlog

  and

  jeqo

  authored
  a745f12

  Copy full SHA for a745f12

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 8303c40
  

  ImFlog

  and

  jeqo

  authored
  8303c40

  Copy full SHA for 8303c40

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 1da53fb
  

  ImFlog

  and

  jeqo

  authored
  1da53fb

  Copy full SHA for 1da53fb

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 3c1f04b
  

  ImFlog

  and

  jeqo

  authored
  3c1f04b

  Copy full SHA for 3c1f04b

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 933d101
  

  ImFlog

  and

  jeqo

  authored
  933d101

  Copy full SHA for 933d101

• Update instrumentation/kafka-streams/src/main/java/brave/kafka/streams/KafkaStreamsTracing.java

  Show description for 85a4c4a
  

  ImFlog

  and

  jeqo

  authored
  85a4c4a

  Copy full SHA for 85a4c4a

• docs: describe mark and rename name -> spanName

  jeqo

  committed
  9daac4a

  Copy full SHA for 9daac4a

Commits on Nov 29, 2018

• fix: typo

  jeqo

  committed
  960ae7a

  Copy full SHA for 960ae7a