All Versions
23
Latest Version
Avg Release Cycle
39 days
Latest Release
1253 days ago

Changelog History
Page 1

  • v2.1.0-M1 Changes

    October 23, 2020

    πŸ“š Release notes in the Alpakka Kafka documentation

    The Alpakka Kafka 2.1 series features

    • Kafka 2.6.0 client
    • Akka 2.6.x (dropped Akka 2.5)
    • Scala 2.12 and 2.13 (dropped Scala 2.11)
    • βœ… Testkit: use ScalaTest 3.1.x
    • βœ… Testkit: default to Confluent Platform 6.0.0
    • βœ… Testkit: no longer support Embedded Kafka (Kafka 2.6.0 can't be safely embedded in Scala applications)
  • v2.0.5 Changes

    September 09, 2020

    πŸ“š Release notes in the Alpakka Kafka documentation

    πŸ”„ Changes

    Alpakka Kafka core

    • πŸ—„ RestrictedConsumer: correct deprecation since version #1197 by @ennru
    • πŸ‘ Allow typed Actor Systems in SendProducer and DiscoverySupport #1192 by @ennru
    • πŸ—„ Deprecate RestrictedConsumer.committed(TopicPartition) #1178 by @seglo
    • πŸ— Cleanup build warnings #1177 by @seglo
    • 🌲 Order logging params for RetriableException consumer failures #1168 by @seglo

    βœ… Tests

    • ⬇️ Reduce bloat of log when testsuite log reported in failed travis build #1182 by @seglo
    • βœ… Simplify consuming stream for AssignmentSpec "consume from the specified topic pattern" test #1181 by @seglo
    • βœ… Cleanup testcontainers docs snippets #1180 by @seglo
    • πŸ— Cleanup build warnings #1177 by @seglo

    βœ… Alpakka Kafka Testkit

    πŸ“š Documentation

    • πŸš€ 2.0.5 Release notes #1199 by @ennru
    • βš™ Run & materialize stream in Akka Cluster Sharding Example #1190 by @seglo
    • πŸ“„ docs: update Akka version #1198 by @ennru

    ⚑️ Updates

  • v2.0.4 Changes

    July 22, 2020

    πŸ“š Release notes in the Alpakka Kafka documentation

    Alpakka Kafka core

    Alpakka Kafka Akka Cluster Sharding

    • ⚑️ Use bulk update API for shard allocation #1139 by @chbatey
    • 🌲 Don't use ctx.log in KafkaClusterSharding #1138 by @chbatey

    βœ… Alpakka Kafka Testkit

    • πŸ—„ Deprecate embedded kafka support #1136 by @seglo
    • βœ… Replace embedded kafka with schema registry with testcontainers #1135 by @seglo
    • βž• Add produce consume check to KafkaContainerCluster #1131 by @seglo

    ⚑️ Updates

  • v2.0.3 Changes

    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 Changes

    February 20, 2020

    πŸ“š Release notes in the Alpakka Kafka documentation

    Alpakka Kafka core

    βœ… Alpakka Kafka Testkit

  • v2.0.1 Changes

    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 Changes

    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 Changes

    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 Changes

    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