effect-kafka

0.7.0

Minor Changes

#30 7d101fb Thanks @Almaju! - add admin api

0.6.0

Minor Changes

#29 d3c8fc0 Thanks @floydspace! - define UnknownProducerError and use it as fallback for all errors happend in producer engine

Patch Changes

#29 d3c8fc0 Thanks @floydspace! - Poll and retry in case QueueFull error raised
#20 4c5f113 Thanks @floydspace! - implement an ability to catch errors raised in MessageRouter handler

0.5.2

Patch Changes

#25 21df29a Thanks @floydspace! - fix esm distro

0.5.1

Patch Changes

d9a8d4d Thanks @floydspace! - fix bug in internal types

0.5.0

Minor Changes

#22 42f2df9 Thanks @floydspace! - Improve build configuration, expose sub packages and fix optional peer dependencies bug, closes #21

0.4.3

Patch Changes

#18 64bbd83 Thanks @floydspace! - proxy more config options for rdkafka
7bd1b0c Thanks @floydspace! - implement in memory kafka instance, closes #9

0.4.2

Patch Changes

0ef48b3 Thanks @floydspace! - forward rdkafka logs, use Logger.withMinimumLogLevel to enable desired log levels, closes #11

0.4.1

Patch Changes

b72be89 Thanks @floydspace! - fix bug when message offered to the queue was not suspended in case of back pressure
b72be89 Thanks @floydspace! - add layerConfig for kafka instance implementations

0.4.0

Minor Changes

4783992 Thanks @floydspace! - rename producer send as sendScoped, and define different send signature

Patch Changes

af964dd Thanks @floydspace! - allow wider range of kafka engines versions

0.3.2

Patch Changes

dd8dea2 Thanks @floydspace! - remove unnecessary peer to @effect/platform
16610c1 Thanks @floydspace! - run consumer scoped

0.3.1

Patch Changes

5f5b329 Thanks @floydspace! - fix consumer layers usage

0.3.0

Minor Changes

c2902e0 Thanks @floydspace! - - rename MessagePayload to ConsumerRecord similar how it is named in zio-kafka
- handle message batches manually
#4 f5d97d2 Thanks @floydspace! - implement stream consumer allow handling commits manually

0.2.0

Minor Changes

ce326b9 Thanks @floydspace! - implement more clean layer configuration, add confluent kafka examples
801815b Thanks @floydspace! - improve connection error handling
58a3803 Thanks @floydspace! - implement producer

0.1.0

Minor Changes

ea84542 Thanks @floydspace! - release first prototype