search

FundingCircle / jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.
https://fundingcircle.github.io/jackdaw/
BSD 3-Clause "New" or "Revised" License
369 stars 80 forks source link

Omitting topic name from aggregation topic configs constructs Materialized incorrectly #262

Open dacreify opened 4 years ago

dacreify commented 4 years ago

Motivation

I needed to add serdes to a reduce operation, but I wanted to let KStreams manage the internal topic vs providing a topic name explicitly.

Repro

Process: Call reduce with a topic-config that omits :topic-name Expected: Materialized instanced without a topic is used Actual: Exception is thrown