What's Changed

• fix: oom by @eschizoid in #67
• fix: upgrade kafka to version 4.2.0 by @eschizoid in #68
• feat: add benchmark graphs by @eschizoid in #69
• fix: rename FunctionalConsumer to KPipeConsumer by @eschizoid in #70
• fix: flaky test by @eschizoid in #71
• fix: interrupted processing by @eschizoid in #73
• feat: Expose Health Check by @matheusandre1 in #74

New Contributors

• @matheusandre1 made their first contribution in #74

Full Changelog: v1.0.0...v1.0.1

What's Changed

• Feature/pipeline optimizations by @eschizoid in #65
• feat: add benchmarks by @eschizoid in #66

Full Changelog: v0.2.1...v1.0.0

What's Changed

• chore: Update Kafka Docker image to soldevelo/kafka. by @igor-soldev in #64
• feat: add metrics for sinks by @eschizoid in #62

New Contributors

• @igor-soldev made their first contribution in #64

Full Changelog: v0.2.0...v0.2.1

What's Changed

• Add README tweaks by @eschizoid in #45
• Add gradle submodules by @eschizoid in #49
• Add java 24 support by @eschizoid in #53
• Implement Offset Manager by @eschizoid in #51
• Feature/add license by @eschizoid in #57
• Add avro support by @eschizoid in #58
• feat: add avro console sink by @eschizoid in #59
• feat: avro console sink tests by @eschizoid in #60
• feat: drain command queue during partition revocation by @eschizoid in #61

Full Changelog: v0.1.0...v0.2.0

Full Changelog: v0.1.3...v0.1.4

What's Changed

• Change java logger by @eschizoid in #1
• Feature/graceful shutdown by @eschizoid in #2
• Add retry tests by @eschizoid in #3
• Add docker plumbing by @eschizoid in #4
• Add MessageSink interface by @eschizoid in #9
• Add fluent config for the kafka consumer by @eschizoid in #11
• Extract metrics functionality into their own classes by @eschizoid in #12
• Add ConsumerRunner to simplify KafkaConsumerApp by @eschizoid in #14
• Refactor main application logic by @eschizoid in #15
• Refactor FunctionalConsumer tests by @eschizoid in #16
• Feature/refactor tests by @eschizoid in #17
• Refactor ConsumerRunner by @eschizoid in #18
• Update readme file by @eschizoid in #19
• Improve consumer state handling by @eschizoid in #25
• Speed up gradle build by @eschizoid in #28
• Implement Sink Registry by @eschizoid in #29
• Prepare first release by @eschizoid in #30
• Fix jacoco reporting path by @eschizoid in #31
• Add GitHub Action for release by @eschizoid in #32
• Add registry tests by @eschizoid in #33
• Remove step for extra tag in release action by @eschizoid in #34
• Add codecov badge by @eschizoid in #35
• Fix release github action by @eschizoid in #36
• Fix release github action (#36) by @eschizoid in #37
• Add maven central publishing step by @eschizoid in #38
• Fix jreleaser gradle dsl by @eschizoid in #39
• Fix jreleaser gradle dsl by @eschizoid in #40
• Fix maven publishing by @eschizoid in #41
• Fix maven publishing by @eschizoid in #42
• Fix maven publishing by @eschizoid in #43
• Fix maven central namespace by @eschizoid in #44

New Contributors

• @eschizoid made their first contribution in #1

Full Changelog: https://github.com/eschizoid/kpipe/commits/v0.1.0