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 0FAB7200CC2 for ; Wed, 5 Jul 2017 12:18:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 0E398162E07; Wed, 5 Jul 2017 10:18:31 +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 551D2162DFF for ; Wed, 5 Jul 2017 12:18:30 +0200 (CEST) Received: (qmail 54808 invoked by uid 500); 5 Jul 2017 10:18:29 -0000 Mailing-List: contact dev-help@manifoldcf.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@manifoldcf.apache.org Delivered-To: mailing list dev@manifoldcf.apache.org Delivered-To: moderator for dev@manifoldcf.apache.org Received: (qmail 4748 invoked by uid 500); 5 Jul 2017 00:10:21 -0000 Delivered-To: apmail-incubator-connectors-dev@incubator.apache.org X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.899 X-Spam-Level: X-Spam-Status: No, score=0.899 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_H2=-1, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=741JXTl2yMa90VrOJ2cA+zs5FEJr0zmcO/ZXJECDESA=; b=uQJ1VTxiphNUH9gFCy9eVyxJwqZYpwL7Un40WjAkYzFBVDTyxzcsbzfB1JGAiHYuvn EzgghDWmVQcYSG/THB0GfxyyBlZiIHcUl0bfRdh7Rn9neyx/1P5TxMRHzFHiHbWhVT0k WQ5OhHrf+Dcq1HdvjkPEg+zsjxpRWLIQW1f9q4wKDGt6lQWYNH8NKU+NLKJpv9d61UiU nf2yFCYwB3tehTHlUq6XFv4uC6DtE36aOxvRsRQkz5myqJaxKIkKMf4jhhwjbAi9CM3I RxaXTgpiQpUZpg4vnjC8vLaUA1+9JSYyg55QiR/db2qapVrPJnFrLfx95RN5k8yzlAI/ b+YA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=741JXTl2yMa90VrOJ2cA+zs5FEJr0zmcO/ZXJECDESA=; b=TjfR3Hq01MKtRThSC5Yqom8VErYgEZ5DFbI6TFYzRi53QKBIcgpLF8q5dZoGLa6Oyj sljSyXGMmFtGR11FUqcqumgIFH0mVrhjCm+//XA9VTGlh2sGDc/Fsn6rwmSwsJonG+e8 UkfL5i/MSwT9EIMNuvRDDYbl13MUKAftuTmG78GrTXCkCaX8oIQxesvblypqZKEGkG8v nRwQ9cheKHFcWYSYTOWarRQWRL8slFyXa2+qhg/XbhNN87RD1f1wWug9VYzDvEFcnxIb nXeNTSwaZ7Jh2fU66bb1Eww6nKW62sVActcwBtREYOcJfy7BqJsjRq1M+jho+RkPFt1a 0soQ== X-Gm-Message-State: AKS2vOyn378pMjhTmzm3iIBBgQqgbbMMQT+4/YIsMPtksm9TzRMijp/1 lDYht+ATDn549f+a4ZFQHuYaiAVgSraG X-Received: by 10.107.141.214 with SMTP id p205mr41230847iod.43.1499213417050; Tue, 04 Jul 2017 17:10:17 -0700 (PDT) MIME-Version: 1.0 From: Clay Teahouse Date: Tue, 4 Jul 2017 19:10:16 -0500 Message-ID: Subject: connector questions To: connectors-dev@incubator.apache.org Content-Type: multipart/alternative; boundary="94eb2c05a3ea2aad68055386d397" archived-at: Wed, 05 Jul 2017 10:18:31 -0000 --94eb2c05a3ea2aad68055386d397 Content-Type: text/plain; charset="UTF-8" Hello All, I have a few questions regarding kafka connect. I'd appreciate your replies. 1) Is there a kafka connector for listening to tcp sockets? 2) If there a protobuf converter that can deal with variable length messages? Meaning read the prefix that specifies the length and use the specified length to read the actual message? thanks Clay --94eb2c05a3ea2aad68055386d397--