0

我有一个使用quarkus-smallrye-reactive-messaging-kafka扩展的 quarkus 应用程序。

在运行时它会产生大量的调试日志:

rent-orchestrator-service    | 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=kafka-consumer-rent-service-events, groupId=rent-orchestrator-service] Added READ_UNCOMMITTED fetch request for partition rent-service-events-0 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka:9092 (id: 1 rack: null)], epoch=0}} to node kafka:9092 (id: 1 rack: null)
rent-orchestrator-service    | 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=kafka-consumer-rent-service-events, groupId=rent-orchestrator-service] Built incremental fetch (sessionId=1774069795, epoch=565) for node 1. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 1 partition(s)
rent-orchestrator-service    | 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=kafka-consumer-rent-service-events, groupId=rent-orchestrator-service] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(rent-service-events-0), canUseTopicIds=True) to broker kafka:9092 (id: 1 rack: null)
rent-orchestrator-service    | 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=kafka-consumer-rent-service-events, groupId=rent-orchestrator-service] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=kafka-consumer-rent-service-events, correlationId=678) and timeout 30000 to node 1: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=1774069795, sessionEpoch=565, topics=[], forgottenTopicsData=[], rackId='')

我试图在中设置不同的日志级别,application.properties但它不起作用:

quarkus.log.level=INFO
quarkus.log.category."org.apache.kafka".level=INFO

我该如何解决?

4

0 回答 0