From jira-return-10969-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Tue Mar 20 14:20:09 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 5B52918064A for ; Tue, 20 Mar 2018 14:20:09 +0100 (CET) Received: (qmail 81386 invoked by uid 500); 20 Mar 2018 13:20:07 -0000 Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: jira@kafka.apache.org Delivered-To: mailing list jira@kafka.apache.org Received: (qmail 81252 invoked by uid 99); 20 Mar 2018 13:20:07 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Mar 2018 13:20:07 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 45677180657 for ; Tue, 20 Mar 2018 13:20:07 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -110.311 X-Spam-Level: X-Spam-Status: No, score=-110.311 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id tsHw7sb9rUrp for ; Tue, 20 Mar 2018 13:20:02 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 2BEB55F5DD for ; Tue, 20 Mar 2018 13:20:02 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 20E23E0D6E for ; Tue, 20 Mar 2018 13:20:01 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 817AA214C0 for ; Tue, 20 Mar 2018 13:20:00 +0000 (UTC) Date: Tue, 20 Mar 2018 13:20:00 +0000 (UTC) From: "Bala Prassanna I (JIRA)" To: jira@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (KAFKA-6690) Priorities for Source Topics MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Bala Prassanna I created KAFKA-6690: --------------------------------------- Summary: Priorities for Source Topics Key: KAFKA-6690 URL: https://issues.apache.org/jira/browse/KAFKA-6690 Project: Kafka Issue Type: Improvement Reporter: Bala Prassanna I We often encounter use cases where we need to prioritise source topics. Such that if a consumer is listening more than one topics, say, HighPriorityTopic and LowPriorityTopic, it should consume events from LowPriorityTopic only when all the events from HighPriorityTopic are consumed. This is needed in Kafka Streams processor topologies as well. -- This message was sent by Atlassian JIRA (v7.6.3#76005)