jackdaw

jackdaw copied to clipboard

# Checklist - [ ] tests - [ ] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section)

mattford63

# Checklist - [ ] tests - [ ] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section)

gphilipp

Avro allows records to be defined recursively. There is an example of a linked list in the Avro specification: ``` { "type": "record", "name": "LongList", "aliases": ["LinkedLongs"], // old name...

afhole

Port to kafka v3.2.0 and update deps

2

Signed-off-by: Greg Haskins

ghaskins

This addresses the following issue: https://github.com/FundingCircle/jackdaw/issues/280 # Checklist - [x ] tests - [x] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section)

dfbernal

With my outstanding PR on 35a8c2f: ``` Reflection warning, jackdaw/streams/interop.clj:271:6 - call to method join on org.apache.kafka.streams.kstream.KStream can't be resolved (argument types: org.apache.kafka.streams.kstream.KStream, org.apache.kafka.streams.kstream.ValueJoiner, org.apache.kafka.streams.kstream.JoinWindows, org.apache.kafka.streams.kstream.Joined). Reflection warning, jackdaw/streams/interop.clj:290:6 -...

nivekuil

Add reduced arity aggregate for windowed streams

1

# Checklist - [x] tests - [x] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section) rebased the old PR. can I get a review?

nivekuil

Implement support for TimestampExtractor

1

Based on the work in https://github.com/FundingCircle/jackdaw/pull/95 Signed-off-by: Greg Haskins # Checklist - [x] tests - [x] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section)

ghaskins

Add support for TopicNameExtractor in `jackdaw.streams/to`

2

As of Kafka v2.0.0, it's been possible to dynamically select the topic to sink to on a per-message basis, using an interface called TopicNameExtractor. This enables some nice routing use...

dysmento

Bump due to security issues

2

Bump the following libs due to a security issue - `io.netty/netty-codec` (CVE-2021-43797) # Checklist - [x] tests - [ ] updated [CHANGELOG](../CHANGELOG.md) (the "unreleased" section)

mthbernardes