kstreamplify
kstreamplify copied to clipboard
michelin
Kstreamplify is a Java library that brings new features on top of Kafka Streams.
## Problem KStreamplify reads all configurations from the Spring Boot context and exposes those under the **kafka.properties** prefix in a static global object, **KafkaStreamsExecutionContext**. ` protected void initProperties() { properties...
Bumps [io.confluent:kafka-streams-avro-serde](https://github.com/confluentinc/schema-registry) from 7.6.0 to 7.6.1. Commits e09b8f9 Set Confluent to 7.6.1, Kafka to 7.6.1. 83b8886 Merge branch '7.5.x' into 7.6.x by rayokota 133881a Merge branch '7.4.x' into 7.5.x by...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
## Problem Documentation on interactive queries does not showcase an actual implementation of an interactive query, leaving the users scratching their heads for it. ## Suggestion A detailled explanation on...
**Kstreamplify** is providing the necessary parameters to configure the `application.server` property required to implement interactive queries. Unfortunately, Kstreamplify does not provide anything to simplify the implementation of interactive queries. The...
## Problem the existing method WindowStoreUtils.get is not enough, because it only takes Instant.now(), which is bad practice. ## Suggestion We should have an additionnal method with a parameter for...
Some production error or deserialization error can be retriable. The production error handler and the deserialization error handler should handle these errors.
## Problem Many Kafka Streams users are more at easy using JSON instead of AVRO, I would like to be able to use KStreamplify as easily with JSON as it's...
## Problem Currently the KafkaError is an Avro object, meaning that anyone using this library needs to have a schema registry on their cluster and use it. ## Suggestion We...
## Problem Join behavior has changed since 3.X, as described in the following links: https://issues.apache.org/jira/browse/KAFKA-13813 https://confluentinc.atlassian.net/browse/KSTREAMS-5249 ## Suggestion Custom utility methods need to be implemented, in a similar logic to...