Commit f5def890 authored by 刘林's avatar 刘林

fix(equip):注释掉kafka日志信息

parent 4bac8166
...@@ -152,16 +152,16 @@ spring.influx.actions=10000 ...@@ -152,16 +152,16 @@ spring.influx.actions=10000
spring.influx.bufferLimit=20000 spring.influx.bufferLimit=20000
#kafka #kafka
spring.kafka.bootstrap-servers=121.199.39.218:9092 spring.kafka.bootstrap-servers=172.16.10.215:9092
spring.kafka.producer.retries=1 spring.kafka.producer.retries=1
spring.kafka.producer.bootstrap-servers=121.199.39.218:9092 spring.kafka.producer.bootstrap-servers=172.16.10.215:9092
spring.kafka.producer.batch-size=16384 spring.kafka.producer.batch-size=16384
spring.kafka.producer.buffer-memory=33554432 spring.kafka.producer.buffer-memory=33554432
spring.kafka.producer.acks=1 spring.kafka.producer.acks=1
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.group-id=messageConsumerGroup spring.kafka.consumer.group-id=messageConsumerGroup
spring.kafka.consumer.bootstrap-servers=121.199.39.218:9092 spring.kafka.consumer.bootstrap-servers=172.16.10.215:9092
spring.kafka.consumer.enable-auto-commit=false spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.auto-offset-reset=earliest spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
......
...@@ -73,12 +73,12 @@ public class KafkaProducerService { ...@@ -73,12 +73,12 @@ public class KafkaProducerService {
future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() { future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
@Override @Override
public void onFailure(Throwable throwable) { public void onFailure(Throwable throwable) {
log.error("发送消息(异步) failure! topic : {}, message: {}", topic, message); // log.error("发送消息(异步) failure! topic : {}, message: {}", topic, message);
} }
@Override @Override
public void onSuccess(SendResult<String, String> stringStringSendResult) { public void onSuccess(SendResult<String, String> stringStringSendResult) {
log.info("发送消息(异步) success! topic: {}, message: {}", topic, message); // log.info("发送消息(异步) success! topic: {}, message: {}", topic, message);
} }
}); });
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment