Browse Source

kafka 输出日志

develop
王兴琳 2 weeks ago
parent
commit
6ce064cbfb
  1. 2
      zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java

2
zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java

@ -46,7 +46,7 @@ public class KafkaTopicProducer {
ProducerRecord<String, String> record = new ProducerRecord<>(topic, event); ProducerRecord<String, String> record = new ProducerRecord<>(topic, event);
RecordMetadata metadata = producer.send(record).get(); RecordMetadata metadata = producer.send(record).get();
// 数据信息 // 数据信息
log.info(record.key(), record.value(), metadata.partition(), metadata.offset()); // log.info(record.key(), record.value(), metadata.partition(), metadata.offset());
} catch (ExecutionException | InterruptedException e) { } catch (ExecutionException | InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} finally { } finally {

Loading…
Cancel
Save