opened
gokulavasan
username_0
…hen initializing worker and error out if we are unable to connect; Sleep for a second, if we get exception in connection in order to print huge overflow of LOG messages since there is no polling wait in the Worker and thus the poll method is executed continuously

Also, modifying the Kafka.json to allow offsets upto -2. And remove description from front end JSON to allow description from backend to surface.


JIRAs:
https://issues.cask.co/browse/CDAP-3798
https://issues.cask.co/browse/CDAP-3793

Build : http://builds.cask.co/browse/CDAP-RBT488
CDAP-3793 and CDAP-3798 : Add a timeout for ZKClient, BrokerService w…
issue
created
gokulavasan
username_0
@username_2 @chtyim Please review. Thanks!
comment
created
nitinmotgi
username_1
Gokul can you provide a very simple description of what is offset. People who use UI and people who use rest API or CLI are different.
comment
created
gokulavasan
username_0
@username_2 Addressed PR comments. Please take a look.
comment
created
albertshau
username_2
:+1:
comment
created
gokulavasan
username_0
@awholegunch Can you rename the ``kafka.default.offset`` field to ``kafka.initial.offset`` in the docs?
comment
created
ajainarayanan
username_3
:+1: on json file changes
comment
created
gokulavasan
username_0
Tested on cluster. Can be merged once @awholegunch has his fixes in.
comment
created
bdmogal
username_4
I am going to merge this. Let's do doc changes in a separate PR.

Thanks @username_0 !
comment