Repository: kylin Updated Branches: refs/heads/2.3.x 353a725c9 -> f0a79ab96
KYLIN-3145 minor, update sample streaming message (#4013) Signed-off-by: shaofengshi <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/37fd9d4d Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/37fd9d4d Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/37fd9d4d Branch: refs/heads/2.3.x Commit: 37fd9d4d3510338a9e35dd9b7fa23c6642176e48 Parents: 353a725 Author: Shaofeng Shi <[email protected]> Authored: Tue Feb 6 16:39:56 2018 +0800 Committer: shaofengshi <[email protected]> Committed: Fri Feb 9 10:04:03 2018 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/kafka/util/KafkaSampleProducer.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/37fd9d4d/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java index 4b91e03..7c8deef 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java @@ -129,6 +129,7 @@ public class KafkaSampleProducer { user.put("id", UUID.randomUUID().toString()); user.put("gender", genders.get(rnd.nextInt(2))); user.put("age", rnd.nextInt(20) + 10); + user.put("first_name", "unknown"); record.put("user", user); //send message ProducerRecord<String, String> data = new ProducerRecord<>(topic, System.currentTimeMillis() + "", mapper.writeValueAsString(record));
