Skip to content
This repository has been archived by the owner on Oct 25, 2021. It is now read-only.

Releases: NeutrinoCorp/quark

Fix multiple consumers per-topic

31 Dec 09:49
Compare
Choose a tag to compare
Pre-release
v0.2.2-alpha

Fix n-consumers per topic

Fix kafka header unmarshal

27 Dec 07:30
Compare
Choose a tag to compare
Pre-release
v0.2.1-alpha

Fix unmarshal kafka headers publish time, Add test

Complete rework and redesigned architecture

26 Dec 08:24
Compare
Choose a tag to compare

This update contains several improvements to the API.

  • Using a net/http package API style
  • Reworked concurrency and parallelism
  • Fix unexpected behavior ended in system panics
  • Segregated consumer registry into a mux
  • Add publishing, currently Kafka is only available
  • Now using kafka headers instead marshaling the whole quark.Message, data encoded in binary
  • Now Quark passes metadata and overall message data within quark.Event struct

Update message fields

13 Dec 09:00
Compare
Choose a tag to compare
Update message fields Pre-release
Pre-release
v0.1.1-alpha

Update message fields

Initial release

13 Dec 03:53
Compare
Choose a tag to compare
Initial release Pre-release
Pre-release
v0.1-alpha

Fix message encoder