Comments (5)
I'm at 1.2.0.RELEASE
and still seeing all this excessive logging.
from spring-cloud-stream-binder-kafka.
Hi @wblancqu,
thanks for reporting this. We'll get this for our next point release. Until we get to it, as per the usual, we encourage users to contribute with any improvements they see fit :).
from spring-cloud-stream-binder-kafka.
@wblancqu,
We are using the same strategy for health checking our applications.
However, I don't believe the KafkaConsumer API allows for passing the aforementioned boolean that the AbstractConfig
utilizes.
In the meantime, we've decided to change the logging level for the ConsumerConfig
as well as the ProducerConfig
to ERROR
. We lose the initial logging on boot up but our logs don't get clustered for each health check.
logging.level.org.apache.kafka.clients.consumer.ConsumerConfig=ERROR
logging.level.org.apache.kafka.clients.producer.ProducerConfig=ERROR
from spring-cloud-stream-binder-kafka.
Hi @ltalhouarne,
Thanks for your reply. We did indeed the same trick:
log4j2.yml:
Configuration:
packages: "org.whatever"
Appenders:
Console:
name: console
target: SYSTEM_OUT
ThresholdFilter:
level: debug
onMatch: ALLOW
PatternLayout:
pattern: '%d [%p] [%t] %c{1.} %m%n'
Loggers:
# Avoid superfluous logging due to health checks
Logger:
- name: org.apache.kafka
additivity: false
level: warn
AppenderRef:
- ref: console
- name: kafka
additivity: false
level: warn
AppenderRef:
- ref: console
- name: org.springframework.cloud.config.client
additivity: false
level: warn
AppenderRef:
- ref: console
Root:
level: info
AppenderRef:
- ref: console
from spring-cloud-stream-binder-kafka.
If you still want the ConsumerConfig
to how up in logs upon startup, you could decrease log level just after kafka binder is started: https://gist.github.com/laur89/bef122a936996d83554353e0601916ae
from spring-cloud-stream-binder-kafka.
Related Issues (20)
- @EmbeddedKafka not working properly with GlobalKTable and transformer HOT 1
- Live producer threads and dynamic-destination-cache-size property HOT 2
- How to wait for future inside Kafka Stream map()? HOT 2
- DefaultErrorHandler not exists HOT 4
- ClassCastException in pipeline: Kafka Streams Function -> Kafka Function -> Kafka Streams Consumer HOT 5
- NOT_ENOUGH_REPLICAS Errors After Upgrading The Spring Boot And Spring Cloud Version HOT 5
- KafkaBinderMetrics prevent JVM shutdown due to not shutting down scheduler thread pool! HOT 8
- Kafka bindings from previous test class remains active in the next test class HOT 2
- Kafka Streams Serdes having nested generic doesn't work HOT 3
- Support for DLQ in batch mode HOT 1
- spring.cloud.stream.bindings.process-in-0.consumer.concurrency not working in case of UpperCase letter in process name HOT 1
- ListenerContainerWithDlqAndRetryCustomizer template points to localhost:9092 HOT 5
- Looking for a sample with AWS MSK IAM
- [Feature Request] Allow to accept a list of customizers instead of a unique one for KafkaMessageChannelBinder HOT 1
- spring-kafka-test is compile (not test) dependency of spring-cloud-stream-binder-kafka-streams:3.2.3 and 3.2.4
- Batch mode is not working HOT 1
- Unknown Autoconfigured KafkaAvroSerializer and KafkaAvroDeSerializers HOT 2
- Spring Cloud stream binder kafka DLQ Handling for Batching doesn't work HOT 2
- Enable DLQ with destinations as pattern
- Fetch message timestamp
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from spring-cloud-stream-binder-kafka.