Release v5.0.0

Release v5.0.0

Release v4.0.4

What's Changed

• modernize nix a little by @michaelglass in #173
• Add headers to consumed/produced records by @sigevsky in #179
• Build in Github Actions by @AlexeyRaga in #183
• Fix CI by @newhoggy in #185
• Do not allow batch poll and rebalance to happen in parallel by @michaelglass in #176
• Fix pointer for header_get_all by @AlexeyRaga in #190

New Contributors

• @michaelglass made their first contribution in #173
• @sigevsky made their first contribution in #179

Full Changelog: v4.0.3...v4.0.4

Release v4.0.3

Changes

• Fix shutdown crash when log/error callback is set The rd_kafka_destroy method may call back into Haskell to perform some logging. This is not allowed when attaching the finalizer using Foreign.ForeignPtr. Hence we switch to Foreign.Concurrent, which allows RdKafka to call back into Haskell. We also disable closing the consumer automatically in the finalizer, this should be done by the application by calling closeConsumer explicitly. by @phile314
• Update librdkafka version to 0.11.6 by @phile314
• Merge pull request #169 from phile314/finalizer Fix shutdown crash when log/error callback is set by @AlexeyRaga
• Clean up imports by @AlexeyRaga
• Release v4.0.3 by @AlexeyRaga

Release v4.0.2

Changes

• Fix delivery callback (fallout from #161) by @phile314
• Make code more readable Co-authored-by: Gauthier S. [email protected] by @phile314
• Merge pull request #168 from phile314/fix_delivery_cb Fix delivery callback (fallout from #161) by @AlexeyRaga
• Release v4.0.2 by @AlexeyRaga

Release v4.0.1

Changes

• Add IsString instance by @newhoggy
• Merge pull request #163 from haskell-works/is-string-instance Add IsString instance by @AlexeyRaga
• Fix stats/socket callback types by @phile314
• Merge pull request #166 from phile314/cb_ints Fix stats/socket callback types by @AlexeyRaga
• Allow rdkafka free stats callback payload by @AlexeyRaga

Release v4.0.0

Changes

• Upgrade to [email protected] by @newhoggy
• Merge pull request #152 from haskell-works/[email protected] Upgrade to [email protected] by @newhoggy
• Support ghc-8.10.2 by @newhoggy
• Test with ghc-8.10.2 by @newhoggy
• Merge pull request #154 from haskell-works/tested-with-ghc-8.10.2 Tested with ghc 8.10.2 by @newhoggy
• Add statistics interval property by @phile314
• Use ByteString instead of String for stats callback This avoids the round-trip via String if one wants to pass the statistics JSON to aeson for further parsing. by @phile314
• Merge pull request #160 from phile314/stats_prop Add statistics interval property by @AlexeyRaga
• Merge pull request #159 from phile314/stats_bs Use ByteString instead of String for stats callback by @AlexeyRaga
• Wrap callbacks in newtype to make wrong usage harder by @phile314
• Merge pull request #161 from phile314/wrapper Wrap callbacks in newtype to make wrong usage harder by @AlexeyRaga
• Release v4.0.0 by @AlexeyRaga

Release v3.1.2

Changes

• tech(nix): Add nettools to shell.nix for ifconfig by @sir4ur0n
• Merge pull request #147 from Sir4ur0n/tech/addNettools tech(nix): Add nettools to shell.nix for ifconfig by @AlexeyRaga
• Upgrade to orb [email protected] by @newhoggy
• Merge pull request #148 from haskell-works/[email protected] Upgrade to orb [email protected] by @newhoggy
• doc: Add documentation on Producer and remaining modules by @sir4ur0n
• Merge pull request #149 from Sir4ur0n/doc/kafkaProducer doc: Add documentation on Producer and remaining modules by @AlexeyRaga
• Disable integration tests by default by @AlexeyRaga
• Merge pull request #150 from haskell-works/disable-integration-tests Disable integration tests by default by @AlexeyRaga
• Bump version: release on Hackage by @AlexeyRaga

Release v3.1.1

Changes

• Disable parallel garbage colllector in CCI tests by @newhoggy
• Disable parallel garbage collector from project.sh test by @newhoggy
• Merge pull request #134 from haskell-works/disable-parallel-garbage-collector-in-cci-tests Disable parallel garbage colllector in CCI tests by @newhoggy
• feat(callback): Change log callback log level to KafkaLogLevel * Int becomes KafkaLogLevel (breaking changes) * Add documentation for callbacks Closes #135 by @sir4ur0n
• Merge pull request #138 from Sir4ur0n/feat/logCallbackKafkaLogLevel feat(callback): Change log callback log level to KafkaLogLevel by @AlexeyRaga
• doc(kafka): Add documentation * Document common types * Document Consumer types and functions * Add module documentation (full example from readme) * Fix links to replacements for deprecated functions by @sir4ur0n
• Dev env and how to run tests by @null
• Get off stack by @null
• Merge pull request #140 from Sir4ur0n/doc/KafkaConsumer doc(kafka): Add documentation by @AlexeyRaga
• Fix hlint by @newhoggy
• Merge pull request #141 from haskell-works/fix-hlint Fix hlint by @newhoggy
• Fix memory leak from not freeing per-message callback pointer by @felixmulder
• Use Foreign.Concurrent.newForeignPtr where applicable This is done in order to get rid of following problem: error: a C finalizer called back into Haskell. This was previously allowed, but is disallowed in GHC 6.10.2 and later. To create finalizers that may call back into Haskell, use Foreign.Concurrent.newForeignPtr instead of Foreign.newForeignPtr. Co-authored-by: Paweł Szulc [email protected] by @lukasz-golebiewski
• Merge pull request #146 from lukasz-golebiewski/use-foreign-concurrent Use Foreign.Concurrent.newForeignPtr where applicable by @AlexeyRaga
• Merge pull request #145 from felixmulder/free-ptr-after-use Fix #143: memory leak from not freeing per-message callback pointer by @AlexeyRaga
• Release v3.1.1 by @AlexeyRaga

Release v3.1.0

Changes

• Add ci build for ghc-8.8.1 by @newhoggy
• Merge pull request #113 from haskell-works/ci-build-for-ghc-8.8.1 Add ci build for ghc-8.8.1 by @newhoggy
• Direct test output and generate environment files by @newhoggy
• Merge pull request #114 from haskell-works/direct-test-output-and-generate-environment-files Direct test output and generate environment files by @newhoggy
• Add hspec-discover to build-tool-depends to test components. by @pranaysashank
• Merge pull request #115 from pranaysashank/master Add hspec-discover to build-tool-depends to test components. by @AlexeyRaga
• Update Readme by @AlexeyRaga
• Upgrade to ghc-8.8.2 in CI by @newhoggy
• Update orbs by @newhoggy
• Merge pull request #122 from haskell-works/upgrade-to-ghc-8.8.2-in-ci Upgrade to ghc-8.8.2 in CI by @newhoggy
• Implement support for callbacks on individual messages by @felixmulder
• Expose assign by @crclark
• Merge pull request #121 from felixmulder/feature/add-message-specific-callbacks Implement support for callbacks on individual messages by @AlexeyRaga
• Merge pull request #123 from crclark/assign-consumer Support for assign() by @AlexeyRaga
• Add example of synchronous production of messages to examples and README by @felixmulder
• Merge pull request #124 from felixmulder/sync-example Add example of synchronous production of messages to examples and README by @AlexeyRaga
• Fix grammar error by @felixmulder
• Merge pull request #125 from felixmulder/sync-example Fix grammar error by @AlexeyRaga
• CI build for ghc-8.8.3 by @newhoggy
• Merge pull request #127 from haskell-works/ci-build-for-ghc-8.8.3 CI build for ghc-8.8.3 by @newhoggy
• Upgrade to [email protected] by @newhoggy
• Merge pull request #128 from haskell-works/[email protected] Upgrade to [email protected] by @newhoggy
• Upgrade to [email protected] by @newhoggy
• Merge pull request #129 from haskell-works/[email protected] Upgrade to [email protected] by @newhoggy
• Remove unused imports by @newhoggy
• Merge pull request #130 from haskell-works/remove-unused-imports Remove unused imports by @newhoggy
• Introduce merge point by @newhoggy
• Merge pull request #131 from haskell-works/use-released-version-of-merge-point Introduce merge point by @newhoggy
• Support ghc-8.10.1 by @newhoggy
• Merge pull request #133 from haskell-works/support-ghc-8.10.1 Support ghc-8.10.1 by @newhoggy
• New version 3.1.0 by @newhoggy

Release v3.0.0

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