v0.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

v0.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

v0.3.2

Patch Changes

• dd8dea2 Thanks @floydspace! - remove unnecessary peer to @effect/platform

• 16610c1 Thanks @floydspace! - run consumer scoped

v0.3.1

Patch Changes

• 5f5b329 Thanks @floydspace! - fix consumer layers usage

v0.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

v0.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

v0.1.0

Minor Changes

• ea84542 Thanks @floydspace! - release first prototype