line/armeria

Add `KafkaLogWriter`

Aperta

#4958 aperta il 15 giu 2023

 (8 commenti) (0 reazioni) (0 assegnatari)Java (863 fork)batch import
good first issuenew feature

Metriche repository

Star
 (4552 stelle)
Metriche merge PR
 (Merge medio 5g 12h) (42 PR mergiate in 30 g)

Descrizione

The default LogWriter uses SLFJ4 to write serialized RequestLogs. In the cloud environment, it would be better to send logs to the remote message queue directly rather than write logs to the local filesystem.

Like KafkaAccessLogWriter, KafkaLogWriter can be added to the armeria-kafka module. https://github.com/line/armeria/blob/d8a744b467271efb4a617584f5d70d8ac140f7f5/kafka/src/main/java/com/linecorp/armeria/server/logging/kafka/KafkaAccessLogWriter.java#L41-L41

public final class KafkaLogWriter implements LogWriter {
    @Override
    public void logRequest(RequestOnlyLog log) {
        // use LogFormatter.ofJson() to convert the log to a JSON object
    }

    @Override
    public void logResponse(RequestLog log) {
        ...
    }
}

Guida contributor