Hi, the sink streams data to some of the caches by definition and those
caches, to my knowledge, are created by you. Don't you set "dataStreamer"
parameters for the Kafka integration? The streamer is always bound to one
of the caches.
-
Denis
On Mon, Dec 9, 2019 at 9:13 AM ashishb888
wrote:
>
Can we query to the caches (that are created/loaded from Ignite sink
connector) from the sqlline?
I have observed that Ignite source connector create a topic with
topicPrefix+SQL+SCHEMA+CACHE_NAME.
Do we have control over this?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Hi,
Unfortunately, Ignite Kafka connector is simple implementation of Kafka
connector that use source and sink functions.
All data transformation and filtering should be done using Kafka API. I
guess that you can try use next functions for your purposes:
https://docs.confluent.io/current
Hi I have subscribe to user-subscr...@ignite.apache.org
,
but still cannot post my question. So I send it directly to this email
address.
Our application receives Kafka message, and then calls invoke to do partial
update. Does ignite kafka connector support invoke ? If not, is Ignite team
going
