feat: share Kafka producers among threads (#1460)
Signed-off-by: Benjamin Voiturier <[email protected]>
Signed-off-by: Benjamin Voiturier <[email protected]>
Signed-off-by: mixmix <[email protected]>
Signed-off-by: mixmix <[email protected]>
Signed-off-by: mixmix <[email protected]>
Signed-off-by: mineme0110 <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]> test: finalized tests and refactoring Signed-off-by: Allain Magyar <[email protected]> Revert "fix: use Kafka 'earliest' offset strategy to avoid missing messages" This reverts commit 241abe8c38f44780a191ecde79562e67c1b0fce7. Revert "chore: reduce Kafka clients lib log verbosity" This reverts commit 8935889b840e2618a3bc4504bd5e9f9ff64f6e21. style: apply linters automatic fixes (#1449) Signed-off-by: Hyperledger Bot <[email protected]> Co-authored-by: Hyperledger Bot <[email protected]> test: removes unused code Signed-off-by: Allain Magyar <[email protected]> style: apply linters automatic fixes (#1456) Signed-off-by: Hyperledger Bot <[email protected]> Co-authored-by: Hyperledger Bot <[email protected]>
Signed-off-by: Benjamin Voiturier <[email protected]>
Signed-off-by: Yurii Shynbuiev <[email protected]>
Signed-off-by: mineme0110 <[email protected]>
Signed-off-by: Hyperledger Bot <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]>
Signed-off-by: Allain Magyar <[email protected]> test: finalized tests and refactoring Signed-off-by: Allain Magyar <[email protected]> Revert "fix: use Kafka 'earliest' offset strategy to avoid missing messages" This reverts commit 241abe8c38f44780a191ecde79562e67c1b0fce7. Revert "chore: reduce Kafka clients lib log verbosity" This reverts commit 8935889b840e2618a3bc4504bd5e9f9ff64f6e21. style: apply linters automatic fixes (#1449) Signed-off-by: Hyperledger Bot <[email protected]> Co-authored-by: Hyperledger Bot <[email protected]> test: removes unused code Signed-off-by: Allain Magyar <[email protected]> style: apply linters automatic fixes (#1456) Signed-off-by: Hyperledger Bot <[email protected]> Co-authored-by: Hyperledger Bot <[email protected]>
Signed-off-by: mineme0110 <[email protected]>
Signed-off-by: Hyperledger Bot <[email protected]> Co-authored-by: Hyperledger Bot <[email protected]>
Signed-off-by: Hyperledger Bot <[email protected]>