Topics tagged kafka

Topic	Replies	Views	Activity
Commiting offsets for Kafka messages that are filtered Akka Streams & Alpakka akka , kafka , streams	1	1291	October 23, 2020
Create Source from Lagom kafka subscriber Lagom kafka , alpakka , streams	0	496	September 18, 2020
What are Cons and pros for KafkaProducer vs SendProducer? Akka Streams & Alpakka kafka	2	784	August 3, 2020
How to persist to Cassandra and publish to Kafka multiple events Akka akka , scala , kafka	1	651	June 28, 2020
Kafka - Ability to react on message publication result Akka Streams & Alpakka kafka , streams	17	4116	June 25, 2020
Is it possible to use ProducerMessage.passThrough with Transaction flow in Alpakka kafka? Akka Streams & Alpakka akka , kafka , streams	0	994	May 15, 2020
Akka kafka consumer parallel processing Akka Streams & Alpakka akka , kafka	5	3440	May 14, 2020
Alpakka with aws msk Akka Streams & Alpakka kafka	1	760	April 30, 2020
Slowing down processing on business errors Akka Streams & Alpakka kafka , alpakka , reactive-kafka , streams	5	3261	April 28, 2020
Writing Big sized messages >1MB with Producer.plainSink Akka Streams & Alpakka kafka	2	3397	April 22, 2020
Configure offset when consuming kafka topic Akka Streams & Alpakka scala , kafka , alpakka	1	1881	April 6, 2020
Alpakka Kafka connector in Akka Streams Akka Streams & Alpakka scala , kafka	2	2187	March 27, 2020
Schema registry fails Akka kafka	1	1300	March 17, 2020
Lazy eval of ProducerMessage.multi Akka Streams & Alpakka scala , kafka	1	1078	November 25, 2019
Lagom multiple TopicProducer in one service Lagom Message Broker API scala , kafka	8	1802	November 5, 2019
Amazon MSK (Kafka) and Alpakka-Kafka Akka Streams & Alpakka kafka , alpakka	0	787	October 2, 2019
Unable to publish/create topic using PubSubRegistry Lagom Service API kafka	5	1413	September 20, 2019
Kafka Retention and Topic Subscriptions Lagom Message Broker API kafka , lagom	2	1214	September 10, 2019
Optional Flow for messages Akka Streams & Alpakka kafka	1	680	September 10, 2019
Unexpected Control.drainAndShutdown behavior Akka Streams & Alpakka kafka	2	1378	August 21, 2019
Kafka partitioning to distribute actors Akka Streams & Alpakka akka , akka-cluster , kafka , streams	0	1074	June 1, 2019
How to implement point to point messaging system using kafka in lagom Lagom kafka	0	1846	May 29, 2019
Status of Kafka Streams Query Project kafka	1	815	May 21, 2019
Inconsistency with subscriber service and parallelism levels Lagom kafka , streams	3	1444	May 14, 2019
Ordered Processing of Messages consumed from Kafka Akka Streams & Alpakka kafka	1	3069	May 13, 2019
How to catch java.net.ConnectException: Connection refused on akka steram? Akka Streams & Alpakka kafka	1	3990	May 10, 2019
How to connect standalone lagom client to kafka events? Lagom scala , kafka	1	851	April 11, 2019
IllegalArgumentException committing offsets: origin stage must be same as other stage with same groupId Akka Streams & Alpakka scala , kafka	2	3366	March 21, 2019
Alpakka Kafka 1.0.1 is available now Akka Streams & Alpakka kafka	0	3086	March 7, 2019
Java examples for Kafka consumer Akka Streams & Alpakka java , kafka	3	4149	February 27, 2019