Skip to content
Pre-release

@ennru ennru released this Dec 3, 2019 · 33 commits to master since this release

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
  • 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

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
  • Producer: change default parallelism #944 by @ennru
  • Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo
Assets 2
You can’t perform that action at this time.