Topics tagged kafka

Topic	Replies	Views	Activity
Slowing down processing on business errors Akka Streams & Alpakka kafka , alpakka , reactive-kafka , streams	5	3326	April 28, 2020
Writing Big sized messages >1MB with Producer.plainSink Akka Streams & Alpakka kafka	2	3463	April 22, 2020
Configure offset when consuming kafka topic Akka Streams & Alpakka scala , kafka , alpakka	1	2057	April 6, 2020
Alpakka Kafka connector in Akka Streams Akka Streams & Alpakka scala , kafka	2	2257	March 27, 2020
Schema registry fails Akka Libraries kafka	1	1348	March 17, 2020
Lazy eval of ProducerMessage.multi Akka Streams & Alpakka scala , kafka	1	1098	November 25, 2019
Amazon MSK (Kafka) and Alpakka-Kafka Akka Streams & Alpakka kafka , alpakka	0	838	October 2, 2019
Optional Flow for messages Akka Streams & Alpakka kafka	1	728	September 10, 2019
Unexpected Control.drainAndShutdown behavior Akka Streams & Alpakka kafka	2	1468	August 21, 2019
Kafka partitioning to distribute actors Akka Streams & Alpakka akka , akka-cluster , kafka , streams	0	1114	June 1, 2019
Status of Kafka Streams Query Project kafka	1	860	May 21, 2019
Ordered Processing of Messages consumed from Kafka Akka Streams & Alpakka kafka	1	3119	May 13, 2019
How to catch java.net.ConnectException: Connection refused on akka steram? Akka Streams & Alpakka kafka	1	4109	May 10, 2019
IllegalArgumentException committing offsets: origin stage must be same as other stage with same groupId Akka Streams & Alpakka scala , kafka	2	3414	March 21, 2019
Alpakka Kafka 1.0.1 is available now Akka Streams & Alpakka kafka	0	3121	March 7, 2019
Java examples for Kafka consumer Akka Streams & Alpakka java , kafka	3	4203	February 27, 2019
Akka.test.single-expect-default must be higher than 5s Akka Streams & Alpakka akka , kafka	4	1435	February 22, 2019
Why TransactionalSource needs isolation.level to be read_committed? Akka Streams & Alpakka kafka	3	2991	January 23, 2019
Transational push of a Kafka Producer Akka Streams & Alpakka kafka	2	1031	January 14, 2019
Case Studies of Alpakka Kafka connector Akka Streams & Alpakka kafka , alpakka , reactive-kafka	1	847	January 8, 2019
Consume-Transform-(not always)Produce with Streams Akka Streams & Alpakka java , configuration , kafka , streams	1	1059	December 28, 2018
How to handle duplication and data loss in akka and kafka Akka Libraries scala , kafka	0	649	November 27, 2018
How to filter log messages coming from alpakka-kafka Akka Libraries kafka , alpakka	1	1130	November 24, 2018
Akka Streams - Kafka offset reset after partition reassignment Akka Streams & Alpakka akka , scala , kafka	1	1742	November 14, 2018
Akka kafka source : batch processing & back pressure / ACK Akka Libraries akka , scala , kafka , streams	2	1942	October 3, 2018
Partitions consumed faster than others Akka Streams & Alpakka kafka	3	1532	September 10, 2018
Are produced messages ordered when using alpakka-kafka's `flexiFlow` and default settings? Akka Streams & Alpakka kafka	2	2081	August 23, 2018
Throughput and batching with Alpakka Kafka Akka Streams & Alpakka kafka	3	4053	August 22, 2018
Solved: Webserver with kafka producer Akka HTTP kafka	4	1621	June 20, 2018
Akka-stream-kafka tuning for low latency Akka Libraries kafka	2	1514	June 12, 2018