ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shro...@apache.org
Subject ignite git commit: IGNITE-4198: Additions to Kafka Streamer README.
Date Wed, 16 Nov 2016 04:00:51 GMT
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 <rshtykh@yahoo.com>
Authored: Wed Nov 16 13:00:33 2016 +0900
Committer: shtykh_roman <rshtykh@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.
 


Mime
View raw message