Open masesdevelopers opened 4 months ago
The code of https://github.com/masesgroup/KNet/blob/9bf7012a0561bf7642a68157c53684a851dfcaed/src/net/KNet/Specific/Connect/KNetSinkTask.cs#L44 can be optimized returning an IEnumerable<SinkRecord>
managed from a specific class able to use Prefetch which prepares SinkRecord
s while the user code uses them.
Tests will be postponed after #429 will be closed: updates and verification will be done with latest Apache Kafka version
Originally posted by @masesdevelopers in https://github.com/masesgroup/KNet/issues/426#issuecomment-1972087844