Return-Path: X-Original-To: apmail-kafka-dev-archive@www.apache.org Delivered-To: apmail-kafka-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D66B110897 for ; Sun, 9 Nov 2014 14:04:23 +0000 (UTC) Received: (qmail 41002 invoked by uid 500); 9 Nov 2014 14:04:23 -0000 Delivered-To: apmail-kafka-dev-archive@kafka.apache.org Received: (qmail 40952 invoked by uid 500); 9 Nov 2014 14:04:23 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 40938 invoked by uid 99); 9 Nov 2014 14:04:23 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 09 Nov 2014 14:04:23 +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 alan.lavintman@gmail.com designates 209.85.192.169 as permitted sender) Received: from [209.85.192.169] (HELO mail-pd0-f169.google.com) (209.85.192.169) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 09 Nov 2014 14:03:56 +0000 Received: by mail-pd0-f169.google.com with SMTP id y10so6161312pdj.14 for ; Sun, 09 Nov 2014 06:03:10 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=eGX/ABWs4lMZrihFuG/AMmgxzkAc0v7HG47bTtoFWtQ=; b=kTYu8HN24Jvx4f/puL1naNZUncNnPRxoRDshroM7QcIq03jfjP6GBFv5v/bJ0xSzZH cyzL1ycTAr0oADu1K+ZZYOpxLqKSrxOwUwFbmnfTa18guw9GprFFACH0SF8GjA9BHs5S s7CwGybSeGBZQ9xLxBfxrbU29nFvqRW+7w4NvILL0YrdmRTTQlp6k7BRuDVq/s7L8gkl GY06HnQF1UIIA7ePYOolwzoXSao4LLZQXz73W5A+O2LARW89AheFJE+wPxvnAcbdZ/YM wiO3XsoXUN0l8MI0UoJCX4YQAsesu2b/NvxsfWTsjkMVXLOjDnzzi4Wa1H9CGFuth25F 9pmw== MIME-Version: 1.0 X-Received: by 10.68.68.235 with SMTP id z11mr25255596pbt.102.1415541790381; Sun, 09 Nov 2014 06:03:10 -0800 (PST) Received: by 10.70.67.138 with HTTP; Sun, 9 Nov 2014 06:03:10 -0800 (PST) Date: Sun, 9 Nov 2014 16:03:10 +0200 Message-ID: Subject: Support for topics+streams at class WildcardStreamsHandler From: Alan Lavintman To: dev@kafka.apache.org Content-Type: multipart/alternative; boundary=001a1137f3b8949d0c05076d811d X-Virus-Checked: Checked by ClamAV on apache.org --001a1137f3b8949d0c05076d811d Content-Type: text/plain; charset=UTF-8 Hi guys, i have seen that if create a message stream by using: createMessageStreams I can define a map with Topic->#Streams Is there a reason why createMessageStreamsByFilter us not giving the same support? I have only a TopicFilter and numStreams interface such as: public List> createMessageStreamsByFilter(TopicFilter topicFilter, int numStreams); But it does not allow me to specify the parallelism per topic. Am I missing something or my assumption is correct? Bests and thanks, Alan. --001a1137f3b8949d0c05076d811d--