Also excption Exception in thread main java.lang.IllegalArgumentException:
 Cannot union streams of different types:
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,org.apache.beam.sdk.coders.AvroCoder@b03f3cea),IntervalWindow)}
  and
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,NullableCoder(org.apache.beam.sdk.coders.AvroCoder@b03f3cea)),IntervalWindow)}
 by just using the raw not NullableCoder

settings.gradle + build.gradle + Changes to KafkaReader

Put inputTopic and bootstrapServer variable inside AbstractPipeline

Lorenz Boguhn authored 3 years ago and Lorenz Boguhn committed 3 years ago

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Lorenz Boguhn authored 3 years ago and Lorenz Boguhn committed 3 years ago

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Lorenz Boguhn authored 3 years ago and Lorenz Boguhn committed 3 years ago

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Lorenz Boguhn authored 3 years ago and Lorenz Boguhn committed 3 years ago

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>

Co-authored-by: Nico Biernat <stu209212@mail.uni-kiel.de>

Co-authored-by: Nico Biernat <stu209212@mail.uni-kiel.de>

Co-authored-by: Nico Biernat <stu209212@mail.uni-kiel.de>

Co-authored-by: Nico Biernat <stu209212@mail.uni-kiel.de>

- Added application-kafkastreams-common project
- modified root gradle project
- configure eclipse quality tools and formatting