Return-Path: X-Original-To: apmail-avro-user-archive@www.apache.org Delivered-To: apmail-avro-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 23EF010327 for ; Wed, 9 Oct 2013 11:16:38 +0000 (UTC) Received: (qmail 92384 invoked by uid 500); 9 Oct 2013 11:16:37 -0000 Delivered-To: apmail-avro-user-archive@avro.apache.org Received: (qmail 91895 invoked by uid 500); 9 Oct 2013 11:16:32 -0000 Mailing-List: contact user-help@avro.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@avro.apache.org Delivered-To: mailing list user@avro.apache.org Received: (qmail 91887 invoked by uid 99); 9 Oct 2013 11:16:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Oct 2013 11:16:31 +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 davidg@inner-active.com designates 213.199.154.14 as permitted sender) Received: from [213.199.154.14] (HELO emea01-am1-obe.outbound.protection.outlook.com) (213.199.154.14) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Oct 2013 11:16:25 +0000 Received: from AMXPR07MB021.eurprd07.prod.outlook.com (10.242.67.141) by AMXPR07MB022.eurprd07.prod.outlook.com (10.242.67.148) with Microsoft SMTP Server (TLS) id 15.0.785.10; Wed, 9 Oct 2013 11:16:02 +0000 Received: from AMXPR07MB021.eurprd07.prod.outlook.com ([169.254.12.244]) by AMXPR07MB021.eurprd07.prod.outlook.com ([169.254.12.244]) with mapi id 15.00.0785.001; Wed, 9 Oct 2013 11:16:02 +0000 From: David Ginzburg To: "user@avro.apache.org" Subject: DataFileWriter thread safty Thread-Topic: DataFileWriter thread safty Thread-Index: AQHOxOBcH2Dz542RZku7dRv6sNupgQ== Date: Wed, 9 Oct 2013 11:16:01 +0000 Message-ID: <06c1be0ba5dd47ec924794f35729d628@AMXPR07MB021.eurprd07.prod.outlook.com> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [79.183.180.115] x-forefront-prvs: 0994F5E0C5 x-forefront-antispam-report: SFV:NSPM;SFS:(199002)(189002)(80976001)(76576001)(74706001)(85306002)(77096001)(56816003)(74876001)(76176001)(76796001)(76786001)(50986001)(47976001)(47736001)(49866001)(4396001)(81542001)(74366001)(51856001)(81342001)(69226001)(46102001)(74316001)(16236675002)(77982001)(65816001)(79102001)(56776001)(54316002)(66066001)(63696002)(83322001)(59766001)(558084003)(81686001)(83072001)(54356001)(53806001)(33646001)(31966008)(81816001)(74662001)(47446002)(24736002);DIR:OUT;SFP:;SCL:1;SRVR:AMXPR07MB022;H:AMXPR07MB021.eurprd07.prod.outlook.com;CLIP:79.183.180.115;FPR:;RD:InfoNoRecords;A:1;MX:1;LANG:en; Content-Type: multipart/alternative; boundary="_000_06c1be0ba5dd47ec924794f35729d628AMXPR07MB021eurprd07pro_" MIME-Version: 1.0 X-OriginatorOrg: inner-active.com X-Virus-Checked: Checked by ClamAV on apache.org --_000_06c1be0ba5dd47ec924794f35729d628AMXPR07MB021eurprd07pro_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi, I am writing a kafka consumer that persists messages into avro record files= . The consumer is a threaded application, but it is unclear to me if DataFile= Writer is thread safe, or I need to add some synchronization code when appending messages ? --_000_06c1be0ba5dd47ec924794f35729d628AMXPR07MB021eurprd07pro_ Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable
Hi,
I am writing a kafka consumer that persists messages into avro record files= .
The consumer is a threaded application, but it is unclear to me if DataFile= Writer is thread safe, or I need to add some synchronization
code when appending messages ?
--_000_06c1be0ba5dd47ec924794f35729d628AMXPR07MB021eurprd07pro_--