Releases · streamnative/kop

08 Jan 02:42

v3.1.1.1

5f92348

v3.1.1.1 Latest

Latest

Bump version to 3.1.1.1

Assets 3

06 Jun 12:15

streamnativebot

v2.11.1.2-b2c38c

9ab8411

v2.11.1.2-b2c38c: Optimize authorization by caching authorization results (#1999)

### Motivation

To follow Kafka's behavior, KoP also performs authorization for each
PRODUCE or FETCH request. If the custom authorization provider is slow
to authorize produce or consume permissions, the performance will be
impacted.

### Modifications

Introduce caches for authorization:
- PRODUCE: (topic, role) -> result
- FETCH: (topic, role, group) -> result;

Add `SlowAuthorizationTest` to verify the producer and consumer won't be
affected significantly by slow authorization.

Introduce two configs to configure the cache policy so that revoke
permission can work:
- kopAuthorizationCacheRefreshMs: the refresh timeout
- kopAuthorizationCacheMaxCountPerConnection: the max cache size

Assets 5