luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
vmware-go-kcl-v2/clientlibrary/worker
History
Tao Jiang 10e8ebb3ff KCL: Fix KCL stops processing when Kinesis Internal Error 
Current, KCL doesn't release shard when returning on error
which causes the worker cannot get any shard because it has
the maximum number of shard already. This change makes sure
releasing shard when return.

update the log message.

Test:
Integration test by forcing error on reading shard to
simulate Kinesis Internal error and make sure the KCL
will not stop processing.

Jira CNA-1995

Change-Id: Iac91579634a5023ab5ed73c6af89e4ff1a9af564
2021-12-20 21:16:38 -06:00
..
checkpointer.go KCL: Fix random number generator 2021-12-20 21:16:38 -06:00
record-processor-checkpointer.go KCL: Update copyright and permission 2021-12-20 21:16:27 -06:00
shard-consumer.go KCL: Fix KCL stops processing when Kinesis Internal Error 2021-12-20 21:16:38 -06:00
worker.go KCL: Fix KCL stops processing when Kinesis Internal Error 2021-12-20 21:16:38 -06:00
worker_test.go KCL: Update copyright and permission 2021-12-20 21:16:27 -06:00