KYLIN-3145 minor, update sample streaming message (#4013) Signed-off-by: shaofengshi <shaofeng...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/50435e11 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/50435e11 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/50435e11 Branch: refs/heads/master Commit: 50435e1143430f3f5c601c1eab22e9fe37c7bf98 Parents: 01bd0d4 Author: Shaofeng Shi <shaofeng...@gmail.com> Authored: Tue Feb 6 16:39:56 2018 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri Feb 9 09:59:01 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/50435e11/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));
