kmq
kmq copied to clipboard
softwaremill
Kafka-based message queue
Clean up old implementation after replacing actors with streams.
- [x] Use new streams in original IntegrationTest - [x] Fix a bug in handling DrainControl in streams which results in IntegrationTest timeout.
PoC of HTTP API. Proposal: provide three operations: * SendMessage * ReceiveMessage * AcknowledgeMessage Simplifications for the PoS: * Connect clients with an existing queue (topic) * No authorization
It is possible to consume from serveral topis as alternative to subscribe on pattern in kafka ?
Hello, Is there any production environments which was used this KMQ. Please let me know. Thanks, Anil.
In my tests I stumbled upon a case where actor system wouldn't shutdown. Turned out that ConsumeMarkersActor was blocked by polling from kafka (https://stackoverflow.com/questions/50268622/kafka-consumer-hangs-on-poll-when-kafka-is-down). It happens if you shut down...
Just wanted to know the use of the disableRedeliveryBefore argument of the marker queue? And as per the logic, I feel the following case scenario would be a failure. for...
Hi, Great work, Just wanted to enquire about any way to restrict number of retries for redelivery a message to a queue. So in case the client is down parmanently,...
Hi! Awesome project! Can some information be added about how Kafka 0.11's exactly once functionality will or won't be incorporated into this work? Are they complementary or orthogonal?
