Okada Haruki

refs: https://github.com/line/decaton/pull/95#issuecomment-797296705 - In principle, we close every Decaton's internal metrics by implementing https://github.com/line/decaton/blob/master/processor/src/main/java/com/linecorp/decaton/processor/metrics/Metrics.java#L64 - But `CompactionProcessor` is an exception * Since there's no way to pass `subscriptionId` upon `CompactionProcessor`...

Embed task metadata in record header

5

## Motivation - Currently, DecatonClient serializes tasks in `DecatonTaskRequest` protobuf format because when Decaton had started, Kafka didn't have record header yet * As Kafka started record header support quite...

## Summary - `testing` module is useful not only for decaton-internal test, but also general Kafka-client integration testing - publish `testing` module to make writing integration-test for users

Add scala implementation

4

- Add Scala(Play 2.6) implementation. - Also I published community AMI:`ami-a031d9c6` that includes Scala app. Thank you for great ISUCON problem.

docs: klip-67: Make internal topic prefix configurable

3

### Description - Propose KLIP-67 * Related issue: #4954 ### Testing done - N/A ### Reviewer checklist - [ ] Ensure docs are updated if necessary. (eg. if a user...

- Currently, Decaton's dynamic property reload is implemented like below: * When dynamic-property change is detected, up "reloadRequested" flag: https://github.com/line/decaton/blob/v5.0.1/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/PartitionContexts.java#L74 - Wait all pending tasks are processed - After that,...

Question about similarity of multiple sketches

5

First of all, thanks a lot for your useful, nice and interesting Java implementation of HyperMinHash. My question is about this: https://github.com/LiveRamp/HyperMinHash-java/blob/master/src/main/java/com/liveramp/hyperminhash/BetaMinHashCombiner.java#L54 As I read `arXiv:1710.08436`, while mergeability is trivial,...

KAFKA-7504 Mitigate sendfile(2) blocking in network threads by waming up fetch data

2

- JIRA ticket: https://issues.apache.org/jira/browse/KAFKA-7504 - This is a long standing issue in current Kafka architecture that calling `FileChannel.transferTo` (which calls sendfile syscall in Linux) in network threads for zero-copy file...

Add JDK21 to CI build target

3

- JDK21 is now GA https://jdk.java.net/21/release-notes