diff --git a/docs/Changelog.md b/docs/Changelog.md index cda2b2c45c2..97c4edf1ca4 100644 --- a/docs/Changelog.md +++ b/docs/Changelog.md @@ -35,6 +35,7 @@ Nussknacker versions * [#1405](https://github.com/TouK/nussknacker/pull/1405) 'KafkaAvroSinkFactoryWithEditor' for more user-friendly Avro message definition. * [#1510](https://github.com/TouK/nussknacker/pull/1510) `FlinkSource` API allows to create stream of `Context` (FlinkSource API and test support API refactoring). * [#1497](https://github.com/TouK/nussknacker/pull/1497) Initial support for multiple (named) schedules in `PeriodicProcessManager` +* [#1499](https://github.com/TouK/nussknacker/pull/1499) ClassTag is provided in params in avro key-value deserialization schema factory: `KafkaAvroKeyValueDeserializationSchemaFactory` 0.3.1 (not released yet) ------------------------ diff --git a/docs/MigrationGuide.md b/docs/MigrationGuide.md index d707b937259..841c626f8c0 100644 --- a/docs/MigrationGuide.md +++ b/docs/MigrationGuide.md @@ -49,6 +49,10 @@ To see biggest differences please consult the [changelog](Changelog.md). - For kafka sources `RecordFormatter` parses raw test data to `ConsumerRecord` which fits into deserializer (instead of `ProducerRecord` that required another transformation). - Definitions of names of common `Context` variables are moved to `VariableConstants` (instead of `Interpreter`). * [#1497](https://github.com/TouK/nussknacker/pull/1497) Changes in `PeriodicProcessManager`, change `PeriodicProperty` to `ScheduleProperty` +* [#1499](https://github.com/TouK/nussknacker/pull/1499) + - trait `KafkaAvroDeserializationSchemaFactory` uses both key and value ClassTags and schemas (instead of value-only), check the order of parameters. + - ClassTag is provided in params in avro key-value deserialization schema factory: `KafkaAvroKeyValueDeserializationSchemaFactory` + - `BaseKafkaAvroSourceFactory` is able to read both key and value schema determiner to build proper DeserializationSchema (support for keys is not fully introduced in this change) ## In version 0.3.0