Как отключить уровень логировния Debug при подключении кафки

231
12 сентября 2021, 00:00

Есть вот такой код:

fun main() {
    val props = Properties()
    props[StreamsConfig.APPLICATION_ID_CONFIG] = "first-stream-app"
    props[StreamsConfig.BOOTSTRAP_SERVERS_CONFIG] = "127.0.0.1:9092"
    props[StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG] = Serdes.String().javaClass
    props[StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG] = Serdes.String().javaClass
    val builder = StreamsBuilder()
    val textLines: KStream<String, String> = builder
                    .stream<String, String>("streams-demo", Consumed.with(Serdes.String(), Serdes.String()))
    fun getWords(line: String): List<String> =
            line.toLowerCase().split("\\W+".toRegex()).dropLastWhile { it.isEmpty() }
    val wordCounts: KTable<String, Long> = textLines
            .flatMapValues { textLine -> getWords(textLine) }
            .selectKey { _, value -> value }
            .groupByKey()
            .count(Materialized.`as`<String, Long, KeyValueStore<Bytes, ByteArray>>("counts-store"))
    wordCounts.toStream().to("streams-demo-out", Produced.with(Serdes.String(), Serdes.Long()))
    val streams = KafkaStreams(builder.build(), props)
    streams.start()
}

При запуске получаю кучу логов в таком формате:

21:04:57.939 [first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1] DEBUG org.apache.kafka.clients.Metadata - [Consumer clientId=first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1-consumer, groupId=first-stream-app] Updated cluster metadata updateVersion 32 to MetadataCache{cluster=Cluster(id = W4eDbi_qRD2udBrJu04BTA, nodes = [192.168.0.15:9092 (id: 0 rack: null)], partitions = [Partition(topic = streams-demo, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = []), Partition(topic = first-stream-app-counts-store-repartition, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = [])], controller = 192.168.0.15:9092 (id: 0 rack: null))}
21:04:58.039 [first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1] DEBUG org.apache.kafka.clients.NetworkClient - [Consumer clientId=first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1-consumer, groupId=first-stream-app] Sending metadata request MetadataRequestData(topics=null, allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node 192.168.0.15:9092 (id: 0 rack: null)
21:04:58.042 [first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1] DEBUG org.apache.kafka.clients.Metadata - [Consumer clientId=first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1-consumer, groupId=first-stream-app] Updating last seen epoch from 0 to 0 for partition streams-demo-0
21:04:58.042 [first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1] DEBUG org.apache.kafka.clients.Metadata - [Consumer clientId=first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1-consumer, groupId=first-stream-app] Updating last seen epoch from 0 to 0 for partition first-stream-app-counts-store-repartition-0
21:04:58.042 [first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1] DEBUG org.apache.kafka.clients.Metadata - [Consumer clientId=first-stream-app-1e30b3db-2237-4560-ac96-19af93aed5bb-StreamThread-1-consumer, groupId=first-stream-app] Updated cluster metadata updateVersion 33 to MetadataCache{cluster=Cluster(id = W4eDbi_qRD2udBrJu04BTA, nodes = [192.168.0.15:9092 (id: 0 rack: null)], partitions = [Partition(topic = streams-demo, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = []), Partition(topic = first-stream-app-counts-store-repartition, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = [])], controller = 192.168.0.15:9092 (id: 0 rack: null))}

Как отключить написание debug логов?

Answer 1

Просто настройте другой уровень логирования для org.apache.kafka. Поищите у себя в проекте файл log4j2.xml или log4j2.properties

READ ALSO
Проверка, авторизован ли пользователь в шаблоне freemarker

Проверка, авторизован ли пользователь в шаблоне freemarker

Разрабатываю проект на Spring MVC, Spring Boot, Spring Security, и в качестве шаблонизатора использую FreemarkerНеобходимо сделать так, чтобы если посетитель сайта...

122
Запрос json к веб-серверу отрабатывает на эмуляторе в Android Sudio, но не работает на реальном устройстве

Запрос json к веб-серверу отрабатывает на эмуляторе в Android Sudio, но не работает на реальном устройстве

В мобильном приложении, разрабатываемом в Android Studio на Java, выполняется обращение веб-серверу с запросом на проверку подключения к БД MS SQL ServerВ...

85
Inlining of methods

Inlining of methods

В книге для подготовки к Java OCP экзамену прочитал следующее

90
Почему такой огромный скачок между датами Date?

Почему такой огромный скачок между датами Date?

Было задание построить график дат, но на графике появились прыжки большие, оказалось проблема в переходе между датами в новый годВ связи...

160