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 E577C200D19 for ; Fri, 6 Oct 2017 13:14:54 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E40621609DF; Fri, 6 Oct 2017 11:14:54 +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 368C41609D0 for ; Fri, 6 Oct 2017 13:14:54 +0200 (CEST) Received: (qmail 98500 invoked by uid 500); 6 Oct 2017 11:14:53 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 98488 invoked by uid 99); 6 Oct 2017 11:14:52 -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, 06 Oct 2017 11:14:52 +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 2BF9D180A8B for ; Fri, 6 Oct 2017 11:14:52 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.629 X-Spam-Level: ** X-Spam-Status: No, score=2.629 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-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 6DhAD6Z-EvFd for ; Fri, 6 Oct 2017 11:14:50 +0000 (UTC) Received: from mail-lf0-f54.google.com (mail-lf0-f54.google.com [209.85.215.54]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 5BA8F5F1BA for ; Fri, 6 Oct 2017 11:14:50 +0000 (UTC) Received: by mail-lf0-f54.google.com with SMTP id l196so20036258lfl.1 for ; Fri, 06 Oct 2017 04:14:50 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=hahUeBuJYA9zRYUqoNdn1C8GkSzvGbb+RtyyXCuQlcE=; b=Yce8YTSdVFxQ08oHfW1DYiyNHOTGAPL/KCU3VZzJvkF38+4ab4YhNQP6zYAlFqHrtL cwHFWbKFPWfpbUDUdtXzpMllGb+EH7MkzWOF37p30Z/5BGHJDyXgBSAdE9jf/ZJgVo9P b4ts4v4wQhvWDGTltSU5UeE25+mo/elcIeCWJjqY3aUek0M2v3rCuokyUZuTCokotyxl 4DwpqNRmzj3i0cayD+WeTEfguRY2yf0MwId0fy4elHeNeaBdvadiZ84JdwfILBnOw7oY GkqJhlke4MR2gr55DP22itcj6Nmjw5S1sQhMnyyQxYe/KvkUdzUYKdOkNvDA5iMNSSjo SolA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=hahUeBuJYA9zRYUqoNdn1C8GkSzvGbb+RtyyXCuQlcE=; b=G8HIKQsFEtaeh+ZwQidS4uNE+csJJ2Iite/E5NQ0qqONlEcfd7v1pgVlMSLPx4m6XB OdAWACCJZrpx1Kx3vJW/MTnFIGuSHDauF09C3clwNL8/4nhRMeTgOGt6E95aIkdRyeES Y86k5zBmJu/kgKCLVabPOnL841SG/XXqClEtM3xiNzrNtT8aqCOXfWd8GHZSUE8W57x4 4DVGrHNpf2eacW1VssjwSDE5yMtG4dM88RFfI8f6yFuuVRTjXNdPKL9eksPkVgkRQUBv VufdXMp3b49Q16QvxBccGJIhNqpj8w/NtYYOQZ2aSdcI/9251bhxSzEhVPO/h9/A9bOs u6jQ== X-Gm-Message-State: AMCzsaV+GmFwF1CQv52StfTpVvzzatApvSS+HY6g+WTAnLNMWaeFIebt WErZmrtUg4g6B1I3qBYxctN6p+Mtf2IvuvSwicfJ X-Google-Smtp-Source: AOwi7QBScKBzhIAw3bvcUD4WD76zePtBX1V7cVf0pMdYlWWPY75FaKX0mBcwACqKOm3tkX9yyFzh6AmM0evX+n7i5ZI= X-Received: by 10.46.33.20 with SMTP id h20mr762395ljh.193.1507288488717; Fri, 06 Oct 2017 04:14:48 -0700 (PDT) MIME-Version: 1.0 Received: by 10.25.228.67 with HTTP; Fri, 6 Oct 2017 04:14:47 -0700 (PDT) In-Reply-To: References: <8D68B0BD-7EC9-4F96-AFE2-9EAC9DA5949C@me.com> From: Andy Taylor Date: Fri, 6 Oct 2017 12:14:47 +0100 Message-ID: Subject: Re: Kafka ServiceConnector To: dev@activemq.apache.org Content-Type: multipart/alternative; boundary="001a1142b41cf1b149055adef28e" archived-at: Fri, 06 Oct 2017 11:14:55 -0000 --001a1142b41cf1b149055adef28e Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable I think https://github.com/ppatierno/kafka-connect-amqp is an example of this On 6 October 2017 at 12:07, Christopher Shannon < christopher.l.shannon@gmail.com> wrote: > Why not use Kafka's Connect framework? Seems like building a source > connector here would make the most sense. This is not to say I'm against > the idea I'm just wondering the benefits of doing it from the Artemis sid= e > of things when Kafka already has a framework that can be used to > import/export data. > > On Fri, Oct 6, 2017 at 6:16 AM, Michael Andr=C3=A9 Pearce < > michael.andre.pearce@me.com> wrote: > > > Hi Andy, > > > > As you may be aware or not we run both activemq and kafka each has a > > specific plus point to it, use the right tool for the right job. > > > > We use activemq as our feature rich, fully jms compliant and performant > > broker. > > > > And use kafka more for post processing and data streaming, with > historical > > feed also. > > > > Idea here is that producers and consumers bind into our activemq where > jms > > api is wanted or needed, lower per message latencies etc. but then we c= an > > bridge messages from a core queue into kafka so that the data can flow = to > > it as fast as possible and consumed from there also. > > > > Idea is to try make a hybrid taking best of both. > > > > Cheers > > Mike > > > > Sent from my iPhone > > > > > On 6 Oct 2017, at 09:37, Andy Taylor wrote: > > > > > > Whats the use case here Michael, sounds like a cool idea and somethin= g > > that > > > has been mentioned by different people but I am yet to understand how > > this > > > could be used. > > > > > > On 6 October 2017 at 07:48, Michael Andr=C3=A9 Pearce < > > > michael.andre.pearce@me.com> wrote: > > > > > >> Hi All, > > >> > > >> I am looking to contribute an artemis ServiceConnector that would > > leverage > > >> the existing service connector interface to bridge from a queue into= a > > >> kafka topic similar to bridge between artemis clusters. > > >> > > >> Idea is to make it configurable how to transform and encode the > message > > in > > >> kafka but as amqp is becoming very well supported by artemis provide > out > > >> the box that the message be encoded in amqp byte protocol. > > >> > > >> It something I=E2=80=99ve been working on privately for a bit, but s= ince > > becoming > > >> a committer here is really like to share it. > > >> > > >> I hope if I get a positive response here to get a branch ready soon, > but > > >> feedback if this is welcomed would be great. > > >> > > >> Cheers > > >> Mike > > >> > > >> > > >> Sent from my iPhone > > > --001a1142b41cf1b149055adef28e--