From issues-return-37179-archive-asf-public=cust-asf.ponee.io@openwhisk.incubator.apache.org Mon May 13 17:32:13 2019 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 [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id E3409180671 for ; Mon, 13 May 2019 19:32:12 +0200 (CEST) Received: (qmail 61749 invoked by uid 500); 13 May 2019 17:32:12 -0000 Mailing-List: contact issues-help@openwhisk.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@openwhisk.incubator.apache.org Delivered-To: mailing list issues@openwhisk.incubator.apache.org Received: (qmail 61740 invoked by uid 99); 13 May 2019 17:32:12 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 May 2019 17:32:12 +0000 From: GitBox To: issues@openwhisk.apache.org Subject: [GitHub] [incubator-openwhisk-package-kafka] dubee opened a new pull request #340: Set consumer state to running after brokers are connected Message-ID: <155776873168.18516.2314772460451464558.gitbox@gitbox.apache.org> Date: Mon, 13 May 2019 17:32:11 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit dubee opened a new pull request #340: Set consumer state to running after brokers are connected URL: https://github.com/apache/incubator-openwhisk-package-kafka/pull/340 Currently the provider sets the consumer state to running when polling begins. However, this is not an accurate state as the call to subscribe a consumer is non-blocking. Meaning polling can begin before a consumer is connected to any brokers. This can be problematic for integration tests that check the consumer health endpoint to see if a consumer is in a running state prior to performing tests. To rectify this problem, the changes here set the consumer state to running only after brokers are assigned to the consumer. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org With regards, Apache Git Services