These 10 commits are when the Protocol Buffers files have changed:
| Commit: | 6cde696 | |
|---|---|---|
| Author: | Oğuzhan Soykan | |
| Committer: | GitHub | |
refactor(standalone-kafka): use StoveSerde<Any,ByteArry> interface to bridge the messages and let users select their ser/de #560 (#664)
The documentation is generated from this commit.
| Commit: | 60e8b52 | |
|---|---|---|
| Author: | Oğuzhan Soykan | |
| Committer: | GitHub | |
spring-kafka: ser/de (#658) * Improvements for spring-kafka to work with StoveSerde interface * add protobuf tests for spring-kafka to make sure that ser/de abstraction works when needed
| Commit: | 3152689 | |
|---|---|---|
| Author: | DariusKlein | |
| Committer: | GitHub | |
Added configuration option for value serializer (#627) * Added configurable value serializer * removed unused import * test implementation kafka streams with protobuf * Added test for deserializer * broke after clean build. fix will come later * Fixed dependencies to user existing libs reintroduced deserialization test example Cleanup * Move dependencies to libs WIP TODO kafka streams (latest version breaks code) rewrite test to kotest * improved comment * tests to kotest * CustomSerde typo fix * removed unused parameter * move kafka streams to libs version * removed runblocking * review: apply more functional assertion and propose removing thread.sleeps * review: solve detekt problem * Removed commented out thread.sleep --------- Co-authored-by: dklein <dklein@afsgroup.nl> Co-authored-by: Oguzhan Soykan <oguzhansoykan@gmail.com>
| Commit: | 264c55d | |
|---|---|---|
| Author: | Oguzhan Soykan | |
standalone-kafka: simplify isCommitted logic
| Commit: | 6eb375e | |
|---|---|---|
| Author: | Oguzhan Soykan | |
| Committer: | Oguzhan Soykan | |
standalone-kafka: also record acknowledged messages
| Commit: | a0a8f78 | |
|---|---|---|
| Author: | Oguzhan Soykan | |
implement healthcheck for kafka sink
| Commit: | a2aecdd | |
|---|---|---|
| Author: | Oguzhan Soykan | |
Handle offsets properly
| Commit: | d60b836 | |
|---|---|---|
| Author: | Oguzhan Soykan | |
shouldBeFailed and shouldBeRetried improved
| Commit: | b77dd12 | |
|---|---|---|
| Author: | Oğuzhan Soykan | |
| Committer: | GitHub | |
Enrich Ktor example with stanalone kafka and and proper configuration handling (#409)
| Commit: | 9b136c4 | |
|---|---|---|
| Author: | Oguzhan Soykan | |
| Committer: | Oguzhan Soykan | |
feature: Standalone kafka now hosts a grpc endpoint to communicate and understand the messages