Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id AC60E200C72 for ; Fri, 12 May 2017 16:06:52 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AAE94160BB8; Fri, 12 May 2017 14:06:52 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id CAC06160BA3 for ; Fri, 12 May 2017 16:06:51 +0200 (CEST) Received: (qmail 99812 invoked by uid 500); 12 May 2017 14:06:45 -0000 Mailing-List: contact user-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@ignite.apache.org Delivered-To: mailing list user@ignite.apache.org Received: (qmail 99793 invoked by uid 99); 12 May 2017 14:06:44 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 12 May 2017 14:06:44 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 325BC18002C for ; Fri, 12 May 2017 14:06:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.88 X-Spam-Level: * X-Spam-Status: No, score=1.88 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id nXlAfTPy0yoT for ; Fri, 12 May 2017 14:06:42 +0000 (UTC) Received: from mail-wm0-f48.google.com (mail-wm0-f48.google.com [74.125.82.48]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 835615FC91 for ; Fri, 12 May 2017 14:06:41 +0000 (UTC) Received: by mail-wm0-f48.google.com with SMTP id d127so16302993wmf.0 for ; Fri, 12 May 2017 07:06:41 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:content-transfer-encoding:mime-version:date:subject:message-id :references:in-reply-to:to; bh=CCesHxGKBWNdNKegthhAC0o/RScyObl1wi7LOeLfGqI=; b=Xh6/jzWCEC7/RXJtOfJbCaNEsB7p+TqEuhUNSgdxByJFom7ywr897PpfE1qMKa1oCn MpfSvohiVNoUpl9fSp6mlluliLCOcYNT+fuf4Qbf6a6qB0rpS5N3bl0UIDskMB851fzP dm1HnK7xIUpHRly4qbeCTUNB1w2+AUQJB4mSxFceRlPcWgaLEgv9EQzcX1b3l8ipjmlv vqRuX4d2omkXD0VFgBWf+euU2714KfWtGTO2IUgmrT2bvT6JErshI3a6p7Oqyml6/fqY tD2+Jayx5mGX94Kvs3nn22CIFDYvUGzJtCuaZOAi8vKfCTfwlLXTMpC5z/bDAesgBiee TSLQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version:date :subject:message-id:references:in-reply-to:to; bh=CCesHxGKBWNdNKegthhAC0o/RScyObl1wi7LOeLfGqI=; b=QN5n6u0iGbhQ/jKEKLxsb+BVsJLMCrX6uxnRSai14kvqZF9r7tJ9OAR2p1uMcsM1n0 CfbC9Yb9M5nAc6whAsWBzNyZ7+JwrnbIByXabGfwD5QoP/GSNXlT30NC0c5HodU5R7Wr 3CTQ0bJXuP77t3RZChMZufSGydqudD45+2A+46D4yYEsevc7pTwoi4zy3jNX0Kt6MSFt ZYOv+pHPvQHEDl7GjC/JN8QV/KbTgWfrADWHgPqOuqqC7p+Ir8DR8Icp4+pmCZAamNe8 EA3lVMB0slpIgNDwqV011B0obCvv0s1dh8GEjQ8CGn/BFp+Kf8iBRfXlct8afaekrh/+ pLtg== X-Gm-Message-State: AODbwcB/X8KvVLwYZpdnusmlvFDAjVGq/iSDJF6Qkjyn1F5Z6kt5QTRp MsuRKSFzJqhalto///k= X-Received: by 10.28.223.195 with SMTP id w186mr3233489wmg.3.1494598000162; Fri, 12 May 2017 07:06:40 -0700 (PDT) Received: from [192.168.178.66] (xdsl-87-78-26-150.netcologne.de. [87.78.26.150]) by smtp.gmail.com with ESMTPSA id x20sm2075243wme.0.2017.05.12.07.06.38 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Fri, 12 May 2017 07:06:38 -0700 (PDT) From: Humphrey Lopez Content-Type: multipart/alternative; boundary=Apple-Mail-A0103CD1-821C-4D42-B6D4-C4BD7CD8BEA2 Content-Transfer-Encoding: 7bit Mime-Version: 1.0 (1.0) Date: Fri, 12 May 2017 16:06:37 +0200 Subject: Re: Kindly tell me where to find these jar files. Message-Id: <53F97F9E-8D46-4163-B0A4-47681FDA2EBD@gmail.com> References: <1494569187445-12649.post@n6.nabble.com> <1494572326330-12650.post@n6.nabble.com> <1494576939728-12653.post@n6.nabble.com> In-Reply-To: <1494576939728-12653.post@n6.nabble.com> To: user@ignite.apache.org X-Mailer: iPhone Mail (14E304) archived-at: Fri, 12 May 2017 14:06:52 -0000 --Apple-Mail-A0103CD1-821C-4D42-B6D4-C4BD7CD8BEA2 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable I'm not able to help you out today but Monday I can send you some code. I us= ed the ignite Kafka streamer to get the messages from Kafka. So ignite is pu= lling from Kafka rather than Kafka pushing to ignite.=20 Humphrey=20 > On 12 May 2017, at 10:15, blasteralfred wrote: >=20 > Hi Humphrey, Thanks for your reply. I am trying to use Kafka Connect for p= ushing to Kafka, and from there, to Ignite, and that's why I have asked for j= ar files. Its okay, that I can try the Stream also. I have no idea on how to= use streams, and the examples I have found were, not in a beginner level (f= or me to understand). Could you be kind enough to show me a sample code to p= ush data to ignite, from kafka? I have pushed data to a kafka topic using Ka= fka connect's file stream source, and in Kafka, the data reside like this; {= "schema":{"type":"string","optional":false},"payload":"hello world 6"} {"sch= ema":{"type":"string","optional":false},"payload":"hello world 7"} {"schema"= :{"type":"string","optional":false},"payload":"hello world 8"} {"schema":{"t= ype":"string","optional":false},"payload":"hello world 9"} {"schema":{"type"= :"string","optional":false},"payload":"hello world 10"} Can you show me a co= de to push this data to Ignite? Thanks in advance..=20 > View this message in context: Re: Kindly tell me where to find these jar f= iles. > Sent from the Apache Ignite Users mailing list archive at Nabble.com. --Apple-Mail-A0103CD1-821C-4D42-B6D4-C4BD7CD8BEA2 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: 7bit
I'm not able to help you out today but Monday I can send you some code. I used the ignite Kafka streamer to get the messages from Kafka. So ignite is pulling from Kafka rather than Kafka pushing to ignite. 

Humphrey 

On 12 May 2017, at 10:15, blasteralfred <blasteralfred@gmail.com> wrote:

Hi Humphrey, Thanks for your reply. I am trying to use Kafka Connect for pushing to Kafka, and from there, to Ignite, and that's why I have asked for jar files. Its okay, that I can try the Stream also. I have no idea on how to use streams, and the examples I have found were, not in a beginner level (for me to understand). Could you be kind enough to show me a sample code to push data to ignite, from kafka? I have pushed data to a kafka topic using Kafka connect's file stream source, and in Kafka, the data reside like this; {"schema":{"type":"string","optional":false},"payload":"hello world 6"} {"schema":{"type":"string","optional":false},"payload":"hello world 7"} {"schema":{"type":"string","optional":false},"payload":"hello world 8"} {"schema":{"type":"string","optional":false},"payload":"hello world 9"} {"schema":{"type":"string","optional":false},"payload":"hello world 10"} Can you show me a code to push this data to Ignite? Thanks in advance..

View this message in context: Re: Kindly tell me where to find these jar files.
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
--Apple-Mail-A0103CD1-821C-4D42-B6D4-C4BD7CD8BEA2--