Skip to content

Handle multiple "TERMINATE" calls for KclRecordProcessor

Compare
Choose a tag to compare
@ebartkus ebartkus released this 12 Jul 09:19
KCLRecordProcessor handles multiple shutdown calls gracefully

In some occasions KCL library calls shutdown multiple times for the
same shards KCLRecordProcessor. We have to make sure it doesn't fail
because closed dependencies.