Deploying Apache Kafka® Streams next to your data

Apache Kafka Streams is a Java library for building scalable, fault-tolerant stream-processing applications that read data from Kafka topics, transform it through operations such as filtering, enrichment, or anomaly detection, and optionally write results to new topics. An Aiven Labs example repository provides a documented, vendor-neutral implementation using Java 25, Gradle, Avro messages in Confluent Wire Format, and both GenericAvroSerde and SpecificAvroSerde approaches, illustrating the trade-off between runtime schema flexibility and compile-time type safety. Its four ready-to-run applications demonstrate logging messages, copying messages unchanged, and filtering logistics data for delivered items while mapping it to a new output schema. The repository includes tests, a Dockerfile, Compose configurations, and instructions for local execution or deployment through Aiven Apps, where users can connect a Kafka service and Karapace schema registry, generate sample logistics data, configure application and topic variables, monitor build and runtime logs, and inspect processed Avro messages.

No tracked trend matches for this post yet.

Use this post, company, and trend context to find content marketing opportunities, perform competitive analysis, or address product feature gaps via the Plushcap MCP server or the Plushcap API.