Skip to content

Stream Reactor 8.1.21

Compare
Choose a tag to compare
@github-actions github-actions released this 16 Dec 15:09
· 28 commits to master since this release
3b8788f

Azure Service Bus source

Performance improvements in the source to handle a higher throughput. The code now leverages prefetch count, and disables the auto complete. The following connector configs were added:

  • connect.servicebus.source.prefetch.count The number of messages to prefetch from ServiceBus
  • connect.servicebus.source.complete.retries.max The maximum number of retries to attempt while completing a message
  • connect.servicebus.source.complete.retries.min.backoff.ms The minimum duration in milliseconds for the first backoff
  • connect.servicebus.source.sleep.on.empty.poll.ms The duration in milliseconds to sleep when no records are returned from the poll. This avoids a tight loop in Connect.