v.4.2.1

• Immediately apply Autothrottle updates
• Minor fixes

v4.2.0

Registry

• All topic and broker fetching RPCs use the kafkaadmin client library rather than reading directly from ZooKeeper
• Updated proto defs; some types have breaking changes
• Updated code gen

topicmappr

• All topic and broker state fetching uses the kafkaadmin client library rather than reading directly from ZooKeeper

kafkaadmin

• Adds the following interface methods:

   UnderReplicatedTopics(context.Context) (TopicStates, error)
   ListBrokers(context.Context) ([]int, error)
   DescribeBrokers(context.Context, bool) (BrokerStates, error)
   GetConfigs(context.Context, string, []string) (ResourceConfigs, error)

• Increased unit and integration test coverage
• Introduces updated Kafka object types with revised metadata

mapper

• Updates several types to be aligned with revised kafkaadmin types
• Adds methods to translate kafkaadmin types to mapper types for drop in compatibility between the deprecated kafkazk and kafkaadmin library

misc.

• Updates repo deps
• Revises Docker config
• Speeds up integration test cycle time
• Updated github workflows

v4.0.0

v4 introduces a breaking change to the kafkazk library by separating any partition mapping logic out from ZooKeeper CRUD ops into the new mapper library. This is part of kafka-kit following Kafka's long-term move away from ZooKeeper.

#402

v3.18.1

registry

• Adds TagBrokers rpc #403

misc.

• Updated docker build params

v3.18.0

autothrottle

• Adds the --kafka-native-mode feature for Kafka RPC based throttle management, improving compatibility with Zookeeperless Kafka releases #399
• Removes deprecated API endpoints

registry

• Explicit broker ID list can be used in create topic requests #400
• SIGTERM shutdowns #401

kafkazk

• fix handling of the metrics prefix flag #398

v3.17.0

topicmappr

• Adds the chunked reassignment feature to the rebuild command #396

kafkaadmin

• Adds the DescribeTopics method #397

v3.16.1

kafkaadmin

Applies dynamic configurations sequentially #393

Misc.

Updates Docker compose for multiple listeners with dynamic port advertisement

v3.16.0

kafkaadmin

#392 Adds the following methods:

SetThrottle(context.Context, ThrottleConfig) error
RemoveThrottle(context.Context, RemoveThrottleConfig) error
GetDynamicConfigs(context.Context, string, []string) (ResourceConfigs, error)

v3.15.0

General

• Adds gitlab CI (private build system use)
• Docker env vars entrypoint wrapper
• Updated deps

cluster

• Adds lock TTLs
• Adds UnlockLogError method
• minor reliability, general improvements

Registry

• Uses TTL'd locks
• Imposes a maximum deadline on RPCs
• Delete tag requests now accepts tags provided as key:value and key

v3.14.0

topicmappr

• Considerable refactor in preparation for a better library structure #387 (thanks @mborst)
• Minor bugfix

kafkazk

• Refactors/cleanup (including the above #387)
• Adds a KIP-455 compatible ListReassignments call