Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 73D1C18569 for ; Sat, 4 Jul 2015 03:01:51 +0000 (UTC) Received: (qmail 82731 invoked by uid 500); 4 Jul 2015 03:01:51 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 82673 invoked by uid 500); 4 Jul 2015 03:01:51 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 82663 invoked by uid 99); 4 Jul 2015 03:01:50 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 04 Jul 2015 03:01:50 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of jrufus@cloudera.com designates 209.85.214.181 as permitted sender) Received: from [209.85.214.181] (HELO mail-ob0-f181.google.com) (209.85.214.181) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 04 Jul 2015 02:59:38 +0000 Received: by obbop1 with SMTP id op1so78196508obb.2 for ; Fri, 03 Jul 2015 20:01:25 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to:content-type; bh=aQa1QMy44MYbK/n/4mMN9X9SiB/61JGvQVf8mG0qT0Y=; b=SUl8jvvAyADccWmF8obHZHEsCfNJ3bD3wPm2zQNn7BLHBSkY0BHAIlD+XbgbqEnLzn 2Ft0cgnxv0xS0U2pDkRKGX6rHSIPv8Ajl3iProCo2iGLX3Q9O/2JUndzmA1mAbRR3J2y dK45L1oZ/ruaMBjT9z7nXXWbsnq7pPmwX4xIcYNXUBd85K3jS7sAWLJw27CTnIdPhS5M pW9A4VzIGurMB3SOB49EBYofPoaK3Qtr8Q5kfXWLUFXvzQJW6AIQEaM7uhvfNf1osWA9 bieQC/0QtufL3Uh+mZEdLJzhSgXfrZpXTWL2zTej6W7gv69rtQDmn3MRZ6TbhpT3i96T Ilpg== X-Gm-Message-State: ALoCoQmKZ1Vard4LlmXeotMUUs97s1FGZOsEj/j3fObhDGacedsiYsvWVW3KeeNjVPkUYP5hoKtx X-Received: by 10.182.65.194 with SMTP id z2mr37246002obs.30.1435978884858; Fri, 03 Jul 2015 20:01:24 -0700 (PDT) MIME-Version: 1.0 Received: by 10.76.146.169 with HTTP; Fri, 3 Jul 2015 20:00:45 -0700 (PDT) In-Reply-To: References: <5C07F644-F9B2-4584-8663-82C768B1BE1B@gmail.com> From: Johny Rufus Date: Fri, 3 Jul 2015 20:00:45 -0700 Message-ID: Subject: Re: Flafka: Kafka channel unable to deliver event To: user@flume.apache.org Content-Type: multipart/alternative; boundary=001a11c1c92456628d051a03e346 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c1c92456628d051a03e346 Content-Type: text/plain; charset=UTF-8 There is a typo in your property "cnannel1", hence the property is not set a1.channels.cnannel1.kafka.consumer.timeout.ms = 1000000 Thanks, Rufus On Fri, Jul 3, 2015 at 4:49 PM, Jun Ma wrote: > Thanks for your reply. But from what I read, the magic things Flafka does > is that you don't need to have a source, you can directly move things from > channel to sink. > > http://blog.cloudera.com/blog/2014/11/flafka-apache-flume-meets-apache-kafka-for-event-processing/ > (see Flume's kafka channel) > > > On Fri, Jul 3, 2015 at 1:26 PM, Foo Lim wrote: > >> There's an error that you didn't specify a source: >> >> Agent configuration for 'a1' has no sources. >> > > --001a11c1c92456628d051a03e346 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
There is a typo in your property "cnannel1", hen= ce the property is not set=C2=A0

a1.channels.cnannel1.kafka.consumer.timeout.ms=C2=A0=3D 1000000
<= /div>

Thanks,
Rufus
=

On Fri, Jul 3, 2015 at 4:49 PM, Jun Ma <mj.saber1990@gmail.com> wrote:
Thanks for your reply. But from what I read, the mag= ic things Flafka does is that you don't need to have a source, you can = directly move things from channel to sink.


On Fri, J= ul 3, 2015 at 1:26 PM, Foo Lim <foo.lim@vungle.com> wrote:<= br>
There's an error tha= t you didn't specify a source:

Agent configuration f= or 'a1' has no sources.


--001a11c1c92456628d051a03e346--