You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sh...@apache.org on 2016/11/16 04:00:51 UTC

ignite git commit: IGNITE-4198: Additions to Kafka Streamer README.

Repository: ignite
Updated Branches:
  refs/heads/master cbada5964 -> 2c64dd062


 IGNITE-4198: Additions to Kafka Streamer README.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2c64dd06
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2c64dd06
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2c64dd06

Branch: refs/heads/master
Commit: 2c64dd06251a7657b71e9c8c908bacce620b3079
Parents: cbada59
Author: shtykh_roman <rs...@yahoo.com>
Authored: Wed Nov 16 13:00:33 2016 +0900
Committer: shtykh_roman <rs...@yahoo.com>
Committed: Wed Nov 16 13:00:33 2016 +0900

----------------------------------------------------------------------
 modules/kafka/README.txt | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/2c64dd06/modules/kafka/README.txt
----------------------------------------------------------------------
diff --git a/modules/kafka/README.txt b/modules/kafka/README.txt
index 259a4f6..686c7ce 100644
--- a/modules/kafka/README.txt
+++ b/modules/kafka/README.txt
@@ -81,6 +81,9 @@ connector.class=org.apache.ignite.stream.kafka.connect.IgniteSinkConnector
 tasks.max=2
 topics=testTopic1,testTopic2
 
+# converter (optional)
+singleTupleExtractorCls=my.company.MyTupleExtractor
+
 # cache
 cacheName=cache1
 cacheAllowOverwrite=true
@@ -90,6 +93,7 @@ where 'cacheName' is the name of the cache you specify in '/some-path/ignite.xml
 will be pulled and stored. 'cacheAllowOverwrite' is set to true if you want to enable overwriting existing values in cache.
 You can also set 'cachePerNodeDataSize' and 'cachePerNodeParOps' to adjust per-node buffer and the maximum number
 of parallel stream operations for a single node.
+If you need to create an Ignite key from a Kafka value, implement StreamSingleTupleExtractor and specify it as 'singleTupleExtractorCls'.
 
 See example-ignite.xml in tests for a simple cache configuration file example.