Authored by zhengwen.ge

增加日志

... ... @@ -19,7 +19,7 @@ public class ClickStreamConsumer implements MessageListener<String, String> {
@Override
public void onMessage(ConsumerRecord<String, String> data) {
logger.info("ClickStreamConsumer request is {}",data);
if (null == data || StringUtils.isEmpty(data.value())) {
logger.warn("kafka onMessage no data");
return;
... ...