1.3.2

Reactor-Kafka 1.3.2 is part of 2020.0.4 release train (Europium SR4).

This release bumps one prod dependency and one test dependency:

• Upgrade kafka-clients to 2.6.1 (#180)
• Update Testcontainers to 1.15.2 (#194)

1.3.1

Reactor-Kafka 1.3.1 is part of the 2020.0.2 Release Train (Europium SR2).

This is a maintenance release that only adapts the bugfix from 1.2.5.RELEASE to the 1.3.x line.

🐞 Bug Fixes

• from 1.2.5.RELEASE:
  • ImmutableSenderOptions.closeTimeout(Duration) setter not taking its argument into account (#184)

1.2.5.RELEASE

Reactor-Kafka 1.2.5.RELEASE is part of the Dysprosium-SR15 Release Train.

This is a maintenance release, with one bugfix.

🐞 Bug Fixes

• Fix ImmutableSenderOptions.closeTimeout(Duration) setter not taking its argument into account (#184)

1.1.3.RELEASE

Reactor-Kafka 1.1.3.RELEASE is part of the Californium-SR23 Release Train.

This is the last release of Californium 👋

This release includes some build polish, and otherwise merely aligns with the latest available core in the Californium line, in order to have clean dependency state for EoL.

1.2.4

⚠️ Technically https://github.com/reactor/reactor-kafka/releases/tag/v1.3.0 is the most recent release ⚠️

This version is a fixup release, as BOM Dysprosium-SR13 did reference an unreleased 1.2.4 by mistake.
The least disruptive way to fix things was to release a "blank" 1.2.4.RELEASE. Note 1.2.3 is effectively skipped.

1.3.0

This release is a result of a major rework of library's internals.
Both consumer and sender were refactored and aligned with the latest developments in reactor-core, resulting in better performance and less bugs.

Upgrade considerations

• By default, Schedulers.immediate is used in both ReceiverOptions and SenderOptions (but it is still configurable). Consider either using Flux#publishOn after calling receive or setting the option. (#154, #158)
• Deprecated mutable options are now replaced with their immutable counterparts. Make sure to always use the resulting options object after setting an option. (#113)

Other changes

• EmbeddedKafka was replaced with Testcontainers to make it easier to run the tests. (#129)

1.3.0-RC1

v1.3.0-RC1

[artifactory-release] Release version 1.3.0-RC1

1.3.0-M2

Release highlights

• Mutable {Sender,Receiver}Options (that were previously deprecated) now replaced with their immutable counterparts. Make sure that you always use the returned value while adjusting the options. (#113 by @alex-dukhno)
• Sender side now uses the immediate Scheduler by default. (#158)

Other changes

• Internal refactorings of the sender side. (#157)

1.2.2.RELEASE

v1.2.2.RELEASE

[artifactory-release] Release version 1.2.2.RELEASE

Reactor Kafka 1.1.0.RELEASE

What's new in Reactor Kafka 1.1.0.RELEASE

This release is a maintenance release. The following are the major updates:

• Align with Reactor 3.2.1.RELEASE version
• Update to Apache Kafka 2.0.0 client
• Stabilize test-suite