CODEWITHSUNDEEP
apache-kafkaapache-kafka-streamsavroconfluent-schema-registry
Mikhail Grinfeld
Mikhail Grinfeld

Reputation: 93

Avro schema from confluent schema registry for kafka-streams groupby (akka aggr) operation

I use schema-registry for all my apps with Kafka Streams. One of our flows makes aggregation and I want to use schema-registry for aggregated object as follows:

stream.groupByKey()
.windowedBy(TimeWindows.of(Duration.of(timeWindowDuration, chronoUnit)))
.aggregate(initAggreggatedObj(), aggregateData(), Materialized.with(Serdes.String(), avroSerde))

But when adding schema to schema-registry, we need to define schema by topic name. In case of aggregation on stream it's impossible, since topic name generated by stream topology.

The question is if there is some way to create schema per any topic to make possible to use by any flow or any other solution?

Upvotes: 0

Views: 319

Answers (1)

Mikhail Grinfeld
Mikhail Grinfeld

Reputation: 93

Thx, OneCricketeer, your response is correct. There is auto.register.schemas parameter which is by default true

Upvotes: 0

Related Questions