conduktor.io ↗

Kafka 3.8 → 3.9 Upgrade Guide

Kafka 3.9 brings 24 new configs, removes 1, and changes 10 defaults compared to 3.8.

+24 configs −1 configs 10 defaults changed 11 KIPs

Removed Configurations

ConfigCategory
group.consumer.migration.policybroker

New Configurations

ConfigCategoryDefault
alter.config.policy.kraft.compatibility.enablebrokerfalse
controller.quorum.bootstrap.serversbroker
group.share.delivery.count.limitbroker5
group.share.heartbeat.interval.msbroker5000 (5 seconds)
group.share.max.groupsbroker10
group.share.max.heartbeat.interval.msbroker15000 (15 seconds)
group.share.max.record.lock.duration.msbroker60000 (1 minute)
group.share.max.session.timeout.msbroker60000 (1 minute)
group.share.max.sizebroker200
group.share.min.heartbeat.interval.msbroker5000 (5 seconds)
group.share.min.record.lock.duration.msbroker15000 (15 seconds)
group.share.min.session.timeout.msbroker45000 (45 seconds)
group.share.partition.max.record.locksbroker200
group.share.record.lock.duration.msbroker30000 (30 seconds)
group.share.session.timeout.msbroker45000 (45 seconds)
remote.log.manager.copier.thread.pool.sizebroker-1
remote.log.manager.expiration.thread.pool.sizebroker-1
sasl.oauthbearer.header.urlencodeconsumerfalse
sasl.oauthbearer.header.urlencodeproducerfalse
remote.log.copy.disabletopicfalse
remote.log.delete.on.disabletopicfalse
sasl.oauthbearer.header.urlencodeconnect_defaultfalse
log.summary.interval.msstream120000 (2 minutes)
processing.exception.handlerstreamorg.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler

Changed Defaults

ConfigOld DefaultNew Default
inter.broker.protocol.version3.8-IV03.9-IV0
ssl.enabled.protocolsTLSv1.2,TLSv1.3TLSv1.2
ssl.protocolTLSv1.3TLSv1.2
ssl.enabled.protocolsTLSv1.2,TLSv1.3TLSv1.2
ssl.protocolTLSv1.3TLSv1.2
ssl.enabled.protocolsTLSv1.2,TLSv1.3TLSv1.2
ssl.protocolTLSv1.3TLSv1.2
ssl.enabled.protocolsTLSv1.2,TLSv1.3TLSv1.2
ssl.protocolTLSv1.3TLSv1.2
client.id<application.id>-<random-UUID><application.id&gt-<random-UUID>

Protocol Changes

Fetch v17 · Fetch v17 · ListOffsets v9 · ListOffsets v9 · FindCoordinator v6 · FindCoordinator v6 · ApiVersions v4 · ApiVersions v4 · Vote v1 · Vote v1 · BeginQuorumEpoch v1 · BeginQuorumEpoch v1 · EndQuorumEpoch v1 · EndQuorumEpoch v1 · DescribeQuorum v2 · DescribeQuorum v2 · FetchSnapshot v1 · FetchSnapshot v1 · BrokerRegistration v4 · BrokerRegistration v4

KIPs Released

KIP-853 KRaft Controller Membership Changes
KIP-932 Queues for Kafka
KIP-950 Tiered Storage Disablement
KIP-956 Tiered Storage Quotas
KIP-1005 Expose EarliestLocalOffset and TieredOffset
KIP-1017 Health check endpoint for Kafka Connect
KIP-1025 Optionally URL-encode clientID and clientSecret in authorization header
KIP-1031 Control offset translation in MirrorSourceConnector
KIP-1033 Add Kafka Streams exception handler for exceptions occurring during processing
KIP-1049 Add config log.summary.interval.ms to Kafka Streams
KIP-1057 Add remote log metadata flag to the dump log tool
Planning a Kafka upgrade? Conduktor Console helps you manage and monitor your clusters during migration.