takaaki shimbo

Provide a way to customize a log format produced by Logging{Service,Client}

13

Motivation: It is described in the following Issue. #3918 Modifications: - Add `LogSanitizers` to hold sanitizers - Add `LogFormat` to convert `RequestLog` into a log message using `LogSanitizers` - Implement...

Provide a way of specifying a partition in producing a task

2

We can inject a custom `org.apache.kafka.clients.producer.Partitioner` by implementing it and passing it through `DecatonClientBuilder#producerConfig`. However, A decaton client wraps a task set by our application in `DecatonTaskRequest`. So, to determine...

Add KafkaLogWriter

5

Motivation: It would be better to send logs to Kafka rather than write logs to the local filesystem. Modifications: - Add `KafkaLogWriter` and `KafkaLogWriterBuilder` - Add `AbstractLogWriterBuilder` to deduplicate builder...

Add default values of new properties to JSON files on CentralDogma when they are supported

1

Currently, `CentralDogmaPropertySupplier#register` creates a default property file if it doesn't exist on CentralDogma. Only the properties that exist at the time are included, so when new properties are supported, they...

I guess we should have a list of all decaton metrics and a monitoring guide. It is useful for users to have appropriate monitoring targets.

Motivation: Described in https://github.com/line/armeria/issues/4648 Modifications: - Add `AsyncClientInterceptor` that returns `ClientCall` with `CompletableFuture` - Add `DeferredClientCall` to execute pending tasks in order when the future returned by `AsyncClientInterceptor` completes. Result:...