[GitHub] [incubator-openwhisk-package-kafka] dubee opened a new pull request #340: Set consumer state to running after brokers are connected

[GitBox <gi...@apache.org>]

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