Skip to content

Release v3.0.0
Compare
Choose a tag to compare
@haskellworksci haskellworksci released this 21 Oct 03:21
v3.0.0
843931a

Changes

  • Add a consumer option to rely on users for polling. by @shlevy
  • Merge pull request #108 from shlevy/user-polling Add a consumer option to rely on users for polling. by @AlexeyRaga
  • CallbackMode by @AlexeyRaga
  • Merge pull request #110 from haskell-works/async-polls Introduce CallbackMode by @AlexeyRaga
  • Move auto-commit from subscription to consumer Fixes a librdkafka deprecation warning: Configuration property auto.commit.enable is deprecated: [LEGACY PROPERTY: This property is used by the simple legacy consumer only. When using the high-level KafkaConsumer, the global enable.auto.commit property must be used instead]. If true, periodically commit offset of the last message handed to the application. This committed offset will be used when the process restarts to pick up where it left off. If false, the application will have to call rd_kafka_offset_store() to store an offset (optional). NOTE: There is currently no zookeeper integration, offsets will be written to broker or local file according to offset.store.method. by @phile314
  • Merge pull request #112 from phile314/move_autocommit Move auto-commit from subscription to consumer by @AlexeyRaga
  • Use assign/pause/redirect/unpause pattern by @AlexeyRaga
  • Remove unnecessary poll for events by @AlexeyRaga
  • Merge pull request #111 from haskell-works/rebalance-pause Use assign/pause/redirect/unpause pattern by @AlexeyRaga
  • Release v3.0.0 by @AlexeyRaga
Assets 3
Loading