Ver código fonte

优化调整

jkzlzhoujie 6 anos atrás
pai
commit
2b10f09cce

+ 2 - 2
src/main/java/com/yihu/ehr/listener/HbaseLogListener.java

@ -32,9 +32,9 @@ public class HbaseLogListener implements EventListener {
            json.put("table",Bytes.toString(sepEvent.getTable()));
            json.put("rowKey",Bytes.toString(sepEvent.getRow()));
            for (Cell cell : sepEvent.getKeyValues()) {
                String key = Bytes.toString(CellUtil.cloneQualifier(cell));
                String cloumn = Bytes.toString(CellUtil.cloneQualifier(cell));
                String value = Bytes.toString(CellUtil.cloneValue(cell));
                json.put(key, value);
                json.put(cloumn, value);
            }
            log.debug("message: " + json.toString());
            producer.sendMessage(json.toString());