From dev-return-94517-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Tue May 22 17:17:04 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 C2C0B180638 for ; Tue, 22 May 2018 17:17:03 +0200 (CEST) Received: (qmail 53386 invoked by uid 500); 22 May 2018 15:17:02 -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 53373 invoked by uid 99); 22 May 2018 15:17:02 -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, 22 May 2018 15:17:02 +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 29A771800C9 for ; Tue, 22 May 2018 15:17:02 +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-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id IKkGWollvFaa for ; Tue, 22 May 2018 15:17:01 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id EFFC65F5F7 for ; Tue, 22 May 2018 15:17:00 +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 8D09FE014A for ; Tue, 22 May 2018 15:17:00 +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 4F868217C4 for ; Tue, 22 May 2018 15:17:00 +0000 (UTC) Date: Tue, 22 May 2018 15:17:00 +0000 (UTC) From: "Guozhang Wang (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (KAFKA-6924) Making state store queryable on replicas MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6924. ---------------------------------- Resolution: Duplicate > Making state store queryable on replicas > ---------------------------------------- > > Key: KAFKA-6924 > URL: https://issues.apache.org/jira/browse/KAFKA-6924 > Project: Kafka > Issue Type: New Feature > Components: streams > Reporter: Navinder Brar > Priority: Major > > State store in Kafka streams are currently only queryable when StreamTask is in RUNNING state. The idea is to make it queryable even for StandbyTasks to decrease the downtime if client is not able to fetch data from Active machine. > Suppose the coordinator is not able to connect to machine which had active partition due to some reason. So, rather than failing that request we could serve request from replica which could be on some other machine. Although state on replica might be little behind the active but it could still be beneficial in some cases to serve request from replica than failing the request. > It's very important improvement as it could simply improve the availability of microservices developed using kafka streams. > I am working on a patch for this change. Any feedback or comments are welcome. > Also, I have gone thorugh https://issues.apache.org/jira/browse/KAFKA-6031, has this been implemented? -- This message was sent by Atlassian JIRA (v7.6.3#76005)