Return-Path: X-Original-To: apmail-kafka-users-archive@www.apache.org Delivered-To: apmail-kafka-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CC24FE367 for ; Thu, 31 Jan 2013 17:05:14 +0000 (UTC) Received: (qmail 91923 invoked by uid 500); 31 Jan 2013 17:05:14 -0000 Delivered-To: apmail-kafka-users-archive@kafka.apache.org Received: (qmail 91865 invoked by uid 500); 31 Jan 2013 17:05:14 -0000 Mailing-List: contact users-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@kafka.apache.org Delivered-To: mailing list users@kafka.apache.org Received: (qmail 91857 invoked by uid 99); 31 Jan 2013 17:05:13 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 31 Jan 2013 17:05:13 +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 (athena.apache.org: domain of jay.kreps@gmail.com designates 209.85.215.48 as permitted sender) Received: from [209.85.215.48] (HELO mail-la0-f48.google.com) (209.85.215.48) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 31 Jan 2013 17:05:09 +0000 Received: by mail-la0-f48.google.com with SMTP id fq13so2079463lab.21 for ; Thu, 31 Jan 2013 09:04:47 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type; bh=kI41blkgiS5VCsKrbFlW6kykHu0U2Zdg5/4F6EEZI0U=; b=QOoymel/7KzfbskOojZ96ldpp1zdEBrrKPTsdkNDncgPJ8KvveyYj8cO2fZYfimAQX gjFs3DSu6LIShEUVb8dkFQOgOnmCFIRvPe4zPaORuOksmz0j0U3KUAkGTbPUIK435HqB 1OQOHVzyIAgyYh9k1rkeYarGcMiyW+C9HAZkCvDqhSusRQiEuJF5aSE1XXG5ZRNRcRvq fBV5KC+kPAxcWhcXFo5boa0o3Owm5+h4y0i6ZWRR5WgcqKvDBMEUIXQup+xPY+rI6jnL TzdDLi3ZzfattDOcztmEybU9J8jwswKS/zMeRgkCX75zoNTM6+PBXXutyZnxx5xg4Hf9 R7qA== MIME-Version: 1.0 X-Received: by 10.152.103.48 with SMTP id ft16mr8561289lab.27.1359651887553; Thu, 31 Jan 2013 09:04:47 -0800 (PST) Received: by 10.114.37.36 with HTTP; Thu, 31 Jan 2013 09:04:47 -0800 (PST) In-Reply-To: References: Date: Thu, 31 Jan 2013 09:04:47 -0800 Message-ID: Subject: Re: S3 Archiving for Kafka topics (with Zookeeper resume) From: Jay Kreps To: users@kafka.apache.org Content-Type: multipart/alternative; boundary=f46d04083e0dc69b3c04d4989faa X-Virus-Checked: Checked by ClamAV on apache.org --f46d04083e0dc69b3c04d4989faa Content-Type: text/plain; charset=ISO-8859-1 This is super cool. Are we linking the right repo on the ecosystem page? https://cwiki.apache.org/confluence/display/KAFKA/Ecosystem -Jay On Thu, Jan 31, 2013 at 1:29 AM, Jibran Saithi wrote: > Hey, > > I know this has come up a few times, so thought I'd share a bit of code > we've been using to archive topics to S3. > > Particularly unimaginatively named, but is available here: > https://github.com/jibs/kafka-s3-consumer > > We needed something with Zookeeper support for storing the offsets, but > didn't come across anything so I quickly put this together. For the moment > I've removed graphite stats reporting because it has a few internal > dependencies, but plan to sort that out soon. > > Hope this helps, > Jibran > --f46d04083e0dc69b3c04d4989faa--