You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by un...@apache.org on 2019/02/13 13:57:33 UTC
[incubator-pinot.wiki] branch master updated: Updated
stream.kafka.decoder.class.name
This is an automated email from the ASF dual-hosted git repository.
unknown pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new cd111e6 Updated stream.kafka.decoder.class.name
cd111e6 is described below
commit cd111e668c92dedf2d7edafe92b44b7a7de2296f
Author: Shaun Schembri <39...@users.noreply.github.com>
AuthorDate: Wed Feb 13 14:57:32 2019 +0100
Updated stream.kafka.decoder.class.name
---
How-To-Use-Pinot.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/How-To-Use-Pinot.md b/How-To-Use-Pinot.md
index 0d2b07d..94c9c78 100644
--- a/How-To-Use-Pinot.md
+++ b/How-To-Use-Pinot.md
@@ -351,7 +351,7 @@ from, using a table definition such as this one:
"streamType": "kafka",
"stream.kafka.consumer.type": "highLevel",
"stream.kafka.topic.name": "flights-realtime",
- "stream.kafka.decoder.class.name": "com.linkedin.pinot.core.realtime.impl.kafka.KafkaJSONMessageDecoder",
+ "stream.kafka.decoder.class.name": "org.apache.pinot.core.realtime.impl.kafka.KafkaJSONMessageDecoder",
"stream.kafka.zk.broker.url": "localhost:2181",
"stream.kafka.hlc.zk.connect.string": "localhost:2181"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org