Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

In this PR we replace the thread-id check with an access-key that allows a callback to pass on its capability to access to the Kafka consumer to another thread.

To keep existing programs working without changes, the access key is stored on a thread-local variable. Developers that work in an async runtime can get the access-key via getThreadAccessKey and then activate it on the thread-local variable in a thread of their choosing with setThreadAccessKey.

...