All Versions
20
Latest Version
Avg Release Cycle
36 days
Latest Release
84 days ago

Changelog History
Page 1

  • v2.0.3

    May 14, 2020

    📚 Release notes in the Alpakka Kafka documentation

    Alpakka Kafka core

    • Committing: retry commits marked as retriable #1111 by @ennru
    • ⚡️ Build: Jackson 2.10.4 and sbt plugin updates #1112 by @ennru
    • 🔒 Security: mask passwords in settings' toString #1110 by @ennru
    • Commit when next offset is observed #1093 by @seglo
    • Non-streaming producer wrapper #1085 by @ennru
    • Simplify commit replying #1095 by @ennru
    • DrainingControl: creation in toMat #1084 by @ennru
    • Simpler use with the new actors API #1088 by @ennru
    • Cluster-sharding: single listener per entity type key + Java DSL #1080 by @chbatey
    • Drain partial offset commit batches on upstream failure #1058 by @sdudzin
    • 👍 Kafka cluster sharding support with external sharding allocation #1067 by @seglo
    • ➕ Add MetadataClient getCommittedOffsets #1073 by @epalace
  • v2.0.2

    February 20, 2020

    📚 Release notes in the Alpakka Kafka documentation

    Alpakka Kafka core

    ✅ Alpakka Kafka Testkit

  • v2.0.1

    January 23, 2020

    📚 Release notes in the Alpakka Kafka documentation

    Alpakka Kafka core

    • Producer: avoid race between failure and upstream finish #1025 by @ennru
    • CommittableProducer: Record outstanding commits on pass-through #1022 by @gabrielreid

    🔄 Changes

  • v2.0.0

    January 15, 2020

    📚 Release notes in the Alpakka Kafka documentation

    Teskit

    Benchmarks

    • Record inflight metrics during benchmarks #1014 by @seglo

    📚 Documentation

    🏗 Build

  • v2.0.0-RC1

    December 16, 2019

    🔄 Changes

    Alpakka Kafka core

    • 🌲 CommittingSpec: add logging #1007 by @ennru
    • Rebalance: filter messages of revoked partitions (partitioned) #992 by @seglo
    • Stage ID traceability #995 by @seglo

    ✅ Tests

    • 🌲 CommittingSpec: add logging #1007 by @ennru
    • Rebalance: filter messages of revoked partitions (partitioned) #992 by @seglo
    • Stage ID traceability #995 by @seglo

    ✅ Alpakka Kafka Testkit

    • Kafka 2.4.0 final #1005 by @ennru
    • 🏗 Build: fail for unformatted Java sources #1003 by @ennru
    • Rebalance: filter messages of revoked partitions (partitioned) #992 by @seglo

    📚 Documentation

  • v2.0.0-M2

    December 03, 2019

    📚 Release notes in the Alpakka Kafka documentation

    🚀 Note: the Alpakka Kafka 2.0.0-M1 release process failed

    Alpakka Kafka core

    • Temporary fix for #978: avoid ConcatIterator #997 by @ennru
    • 🗄 Deprecations: since version 2.0.0 #996 by @ennru
    • ConsumerSetting: Add group instance id setter #861 by @def1ne
    • PartitionAssignmentHandler: add onLost #986 by @ennru
    • ➕ Add partitioned transactional source phase 1 #930 by @seglo
    • 🌲 Stage Logic and Actor logging with ID #991 by @seglo
    • Committing producer sink: producer and committer in a sink stage #963 by @ennru
    • ➕ Add wrapper for Metadata requests #497 #900 by @jewertow
    • Kafka 2.4.0-RC1 #971 by @seglo
    • Commit refreshing: fix bug from aggregating offsets #975 by @ennru
    • 🚀 Producer: remove unreleased variants; simplify producer passing #967 by @ennru
    • 🗄 Committable: deprecate commitJavadsl and commitScaladsl #959 by @ennru
    • Producer: some concurrency and naming improvements #962 by @ennru
    • DrainingControl: expose failures on overwritten methods #958 by @ennru
    • Rebalance: filter messages of revoked partitions #946 by @ennru
    • Consumer: make partition assignment handler public API #949 by @ennru
    • Pass ProducerSettings to stage #952 by @seglo
    • CommittableOffsetBatch: Handle multiple committer refs #953 by @ennru
    • 0️⃣ Producer: change default parallelism #944 by @ennru
    • ✂ Remove methods deprecated before 1.0 #945 by @ennru
    • ✅ Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo
    • 👍 Akka Discovery support #836 by @ennru
    • Mima 0.6.0 and exclusions for #931 #937 by @ennru
    • Create committableSink as combination of Producer.flexiFlow an… #932 by @ennru
    • Committer: change type bound to allow offset batches #931 by @ennru

    ✅ Alpakka Kafka Testkit

    • Cleanup KafkaSpec before termination of embedded server #970 by @shobull
    • ✅ Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo

    ✅ Tests

    • ✅ Tests: capture logging to show it for failed tests #993 by @ennru
    • ✅ Use akka.test.timefactor #994 by @seglo
    • 📄 Docs: remove duplicated producer tests #960 by @ennru
    • 👉 Make EmbeddedKafka a provided dependency #954 by @ennru
    • ✅ Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo
    • 📊 Illustrate how max.poll.records affects buffer #865 by @ennru

    📚 Documentation

    • 📄 Docs: more links to API docs #981 by @ennru
    • 📄 Docs: remove duplicated producer tests #960 by @ennru

    Other changes

    • 🚚 Scalafmt: don't remove redundant braces #972 by @ennru
    • ⏱ Akka 2.6.0 in scheduled build #964 by @ennru
    • ⏱ Akka 2.6.0-RC1 for the scheduled build #938 by @ennru
    • ⬆️ Scala 2.13.1 and 2.12.10; plugin and test library upgrades #935 by @ennru

    Benchmarks

    • Committing producer sink: producer and committer in a sink stage #963 by @ennru
    • 0️⃣ Producer: change default parallelism #944 by @ennru
    • ✅ Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo
  • v2.0.0-M1

    December 03, 2019
  • v1.1.0

    October 10, 2019

    📚 Release notes in the Alpakka Kafka documentation

    🔄 Changes

    • 🔒 Testkit & tests: Sort out some dependencies with security warnings #928 by @ennru

    Benchmarks

    • Benchmarks: don't reuse topics for raw batched consumers #922 by @ennru
    • Benchmarks: try fresh topic for batched consumer 5000k #919 by @ennru

    ✅ Tests

    📚 Documentation

  • v1.1.0-RC2

    October 02, 2019

    📚 The release notes are in the Alpakka Kafka documentation.

    🔄 Changes since Alpakka Kafka 1.1.0-RC1

    • 🏗 Cron builds: allow compiler warnings #916 by @ennru
    • 🏗 Akka 2.6.0-M8 for nightly builds #914 by @ennru
    • ⚡️ CI: update Adopt Open JDK versions #913 by @ennru
    • 🚀 Configure autolabeler bot; update release helpers #897 by @ennru

    Benchmarks

    • ✅ Benchmarks: create new topics for producers tests #917 by @ennru
    • Benchmarks: try producing with even more ridiculous parallelism #907 by @ennru
    • Benchmarks: try producing with ridiculous parallelism #906 by @ennru
    • Benchmarks: producer writing 500 bytes messages #902 by @ennru
    • Benchmarks: Create topics with data only once per run #898 by @ennru
    • Benchmarks: await all messages #896 by @ennru

    Alpakka Kafka core

    • 👀 Committable partitioned source with manual offset seek support #908 by @seglo

    ✅ Tests

    • 👀 Committable partitioned source with manual offset seek support #908 by @seglo

    📚 Documentation

    • 🚀 Release notes for 1.1.0-RC2 #918 by @ennru
    • 👀 Committable partitioned source with manual offset seek support #908 by @seglo
    • Clarify exactly-once-semantics limitations #903 by @raboof
  • v1.1.0-RC1

    September 05, 2019

    🔄 Changes

    • Introduce setting for committing without backpressure #883 by @ennru
    • Capture exceptions from Kafka consumer and pass to involved stages #887 #887 by @ennru
    • Switch to torkild credentials #893 by @2m
    • 🏗 No Scala 2.11 for nightly builds #888 by @2m
    • IntegrationSpec: simplify counting to understand failures #879 by @ennru
    • ⚡️ Update to Lightbend Community Code of Conduct #878 by @TimMoore
    • ➕ Add producer benchmark with partitions #876 by @ennru
    • ✅ Split testing with different Scala version to separate Travis jo… #877 by @2m
    • ⬆️ Upgrade to the latest scalafmt #875 by @2m
    • 🚚 Move data perparation to the batch implementation #873 by @ennru
    • ⏪ Revert benchmark numbers #871 by @ennru
    • 🚚 Offset batch: remove intermediary structure #870 by @ennru
    • Micro optimisation: Check batchSize to avoid map transformation #869 by @ennru
    • Special casing single offset committing #868 by @ennru
    • 📊 Extra poll after receiving commit data #866 by @ennru
    • Commit refreshing not required after Kafka 2.1 #860 by @ennru
    • Commit refreshing: avoid extra work #867 by @ennru
    • 📊 Aggregate offsets and commit before poll #862 by @ennru
    • 📄 Docs: Akka Paradox theme 0.23 #863 by @ennru
    • 🚀 Release train updates #858 by @TimMoore
    • ⚡️ Scalafmt: update plugin to 2.0.3 #856 by @ennru
    • 📚 Corrects a documentation error for Consumer docs #855 by @bwmcadams

    📚 Documentation

    • 📄 Docs: security setup #891 by @ennru
    • 🛠 Fix package name; add links to Alpakka #890 by @ennru
    • ➕ Add page descriptions for HTML meta tags #889 by @ennru
    • ✂ Remove pre-1.0 release notes from ToC #885 by @ennru
    • 📄 Revise Committing docs #881 by @ennru
    • 📄 Docs: project info plugin 1.1.3 #857 by @ennru