cookie-cutter icon indicating copy to clipboard operation
cookie-cutter copied to clipboard

Published 20 hours ago • verified publisher icon walmartlabs

Investigate INVALID_TXN_STATE Error

Open sklose opened this issue 5 years ago • 1 comments

Error code: 48, type: INVALID_TXN_STATE is thrown when a transaction is aborted before the transaction has had send called on it. This results in the transaction falling in an invalid state and the KafkaSink needs to be disposed and re-initialized (this disconnects the kafkajs.Producer which created the transaction and creates a new one).

This issues is dependent on a change in KafkaJS. Once they have a fix we can modify the KafkaTransactional.integration.test.ts file to not call dispose() and initialize() a second time.

Issue tracking: https://github.com/tulios/kafkajs/issues/469

sklose avatar Jan 20 '20 14:01 sklose

Kafkajs does not seem to be working on this issue. Last comment was on Nov 10, 2019

plameniv avatar Jul 12 '21 19:07 plameniv