Alpakka Project Contributor Experience
summary
Describes Alpakka’s practical Akka Streams connectors and demonstrates building a back-pressured connector for Apache Geode using nonblocking APIs, futures and a completion counter. Covers techniques to avoid thread blocking (semaphores, executor isolation) and how to determine stream completion only after pending asynchronous writes finish; notes the project already provides 23 connectors and that the implementation was tested end-to-end and entered the community review workflow.
AI-written summary · about
chapters (11)
- 0:00Alpakka intro
- 1:04Community evolution
- 2:07Connector concepts
- 3:12Flow graph architecture
- 5:41Futures and callbacks
- 7:12Concurrency and APIs
- 10:43Resource management
- 14:48Back-pressure in connectors
- 17:43Contributor benefits
- 20:31Contribution process
- 23:16Conclusion
related talks
40mInteractive Session - Live Code Contribution to Apache Flink
50mFrom dev@ to user@ to the Apache Way
18mBuilding an ACP-Compatible Agent Live
41mAkka support
44mApache Zeppelin: A friendlier way to Flink
32mFrom Design to Code using AsyncAPI
26mStéphane Nicoll and Madhura Bhave
39mIntroduction to AsyncAPI for Apache Kafka
