Messages by Thread
-
[jira] [Created] (KAFKA-20952) Remove hamcrest from org.apache.kafka.streams.kstream package
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20951) StreamsMetricsImpl retains duplicate sensor names when a sensor is removed and recreated
chomingi (Jira)
-
[jira] [Created] (KAFKA-20950) Remove hamcrest from org.apache.kafka.streams.state package
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20949) Remove hamcrest from org.apache.kafka.streams.query package
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20948) Migrate hamcrest tests to JUnit
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20947) ZkWriteSnapshotTimeMs metric reports negative values
Michael Westerby (Jira)
-
Community over Code Glasgow 2026 Hackathon - Action Needed
Bowen, Rich
-
[jira] [Created] (KAFKA-20946) Rewrite SaslPlaintextConsumerTest with dynamic sasl configurations
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20945) [CVE-2026-9828] , [ CVE-2026-10532] [logback-core] [1.5.25]
Krishna Chidrawar (Jira)
-
Minor consistency: subscribedTopicNames/regex bypass the DESCRIBE-TOPIC filter in ConsumerGroupDescribe/ShareGroupDescribe
Mike Read
-
[jira] [Created] (KAFKA-20945) [CVE-2026-9828] [logback-core] [1.5.25]
Krishna Chidrawar (Jira)
-
Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #218
Apache Jenkins Server
-
[jira] [Created] (KAFKA-20944) Add (E2E) tests for kafka-server-stop.sh
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20943) Upgrade Develocity related Gradle plugin versions
Jira
-
[jira] [Created] (KAFKA-20942) Refactor empty catch blocks in clients module tests to use assertThrows().
Kapil Hadoltikar (Jira)
-
[jira] [Created] (KAFKA-20941) Replace HTMLTestRunner
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20813) docker_build_test.py doesn't like podman
Chia-Ping Tsai (Jira)
-
[Please approve GitHub workflow runs] Gradle build related PR's
Dejan Stojadinović
-
[PR] MINOR: Fix broken "Create documentation issue" link [kafka-site]
via GitHub
-
[jira] [Created] (KAFKA-20940) Windowed changelog restore optimization is skipped whenever a checkpointed offset exists
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20939) Client applications broken by DNS resolution failure behaviour change
Andrew Schofield (Jira)
-
[jira] [Resolved] (KAFKA-20936) Bump lz4 to 1.11.2
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20682) Implement IQv2 for headers-aware state stores
Jess Jin (Jira)
-
[jira] [Resolved] (KAFKA-20852) buffer + doc PR
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20938) Previous JoinGroup/SyncGroup requests left dangling when retried
Sean Quah (Jira)
-
[jira] [Resolved] (KAFKA-20937) Bump lz4 to 1.11.2
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20937) Bump lz4 to 1.11.2
Jira
-
[jira] [Created] (KAFKA-20936) Bump lz4 to 1.11.2
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-20935) Kafka: lz4-java ( CVE-2026-59949 )
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20935) Kafka: lz4-java ( CVE-2026-59949 )
Krishna Chidrawar (Jira)
-
[jira] [Resolved] (KAFKA-20931) Kraft network client doesn't handle certificate rotation
Christo Lolov (Jira)
-
[jira] [Resolved] (KAFKA-20929) ConnectStandaloneFileTest fails on FIPS-enabled systems due to MD5 usage
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-20819) StreamThread hangs forever in TaskManager.waitForFuture() after its StateUpdater thread dies, silently dropping out of the consumer group
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20724) Topology pausing may have race condition
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20610) Abstract ReplicaManager dependency from SharePartition
Apoorv Mittal (Jira)
-
[jira] [Resolved] (KAFKA-20693) NPE in error handling in AbstractHerder
Chia-Ping Tsai (Jira)
-
Re: [SECURITY] Kafka Connect REST API — Unauthenticated Arbitrary File Read, SSRF, and Credential Theft via Default Configuration
ASF Security
-
[jira] [Resolved] (KAFKA-20618) Streams Group Topology Description Plugin
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20169) Support static membership for Kafka Streams with the streams rebalance protocol
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to 10.10.1
Matthias J. Sax (Jira)
-
[VOTE] KIP-1362: Add a rollback-compatible storage format option for KRaft migration
Anton Agestam via dev
-
[jira] [Resolved] (KAFKA-19902) Consumer triggers OFFSET_OUT_OF_RANGE when committed offset uses stale epoch after leader change
Lianet Magrans (Jira)
-
[jira] [Resolved] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20934) Considering Share Groups for decoupling stateless Kafka Streams processing parallelism from source partitions
sanghyeok An (Jira)
-
[jira] [Created] (KAFKA-20933) RocksDBStore.putAll bypasses the transaction buffer
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-20930) Make offload config private for 4.4
Sean Quah (Jira)
-
[ANNOUNCE] Code freeze for Apache Kafka 4.4.0
Omnia Ibrahim
-
[jira] [Created] (KAFKA-20932) RemoteLogLeaderEpochState loses replaced segments from leader epoch listings
GiminKim (Jira)
-
[jira] [Resolved] (KAFKA-20323) Refactor test method to enable Mockito version upgrade
chomingi (Jira)
-
[jira] [Resolved] (KAFKA-17754) A delayed EndTxn message can cause aborted read, lost writes, atomicity violation
Justine Olshan (Jira)
-
[jira] [Resolved] (KAFKA-16517) Do not decode metadata records in the internal kraft partition listener
Jira
-
[jira] [Resolved] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Ziyun Fu (Jira)
-
[jira] [Resolved] (KAFKA-20891) Mark unused "streams" protocol configs internal
Matthias J. Sax (Jira)
-
[Please provide `ci-approved` label] Gradle build releated PR's
Dejan Stojadinović
-
[jira] [Created] (KAFKA-20931) Kraft network client doesn't handle certificate rotation
Christo Lolov (Jira)
-
[jira] [Created] (KAFKA-20930) Make offload config private for 4.4
Sean Quah (Jira)
-
[jira] [Resolved] (KAFKA-20409) Don't expose internal group configs unless they are user-defined.
Sean Quah (Jira)
-
[jira] [Reopened] (KAFKA-20036) Handle LogCleaner segment overflow caused by compression level changes
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20807) Refactor ByteBufferOutputStream for better extensibility
Lianet Magrans (Jira)
-
[PR] docs: update broken links in books and papers section [kafka-site]
via GitHub
-
[jira] [Created] (KAFKA-20929) ConnectStandaloneFileTest fails on FIPS-enabled systems due to MD5 usage
Maros Orsak (Jira)
-
[PR] KAFKA-20737: Add CI guard for archived release links [kafka-site]
via GitHub
-
[jira] [Resolved] (KAFKA-20721) Streams: "Task not found in the state updater. This indicates a bug." after a state updater remove times out during cold start rebalancing
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20757) Run store-level unit suites through the transactional path
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Nikita Shupletsov (Jira)
-
[jira] [Resolved] (KAFKA-20711) Streams task restore-remaining-records metric never reaches 0
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-14412) Transactional semantics for StateStores
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-20502) Integration tests for IQv2 transaction isolation
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20927) Introduce new clientInstanceId method with no timeout and deprecate old methods
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20928) Remove deprecated clientInstanceId(Duration) methods in Apache Kafka 5.0
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20926) Only send client ID and client instance ID on initial RPC on each connection
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20925) Introduce new versions of all other RPCs using request header v3
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20924) Introduce request header version 3 in GetTelemetrySubscriptions and PushTelemetry RPCs
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20923) Introduce headerVersions into RPC schema definitions
Andrew Schofield (Jira)
-
[jira] [Created] (KAFKA-20922) TimestampedRangeWithHeadersQuery iterator can NPE on a null-deserialized value (KV path missing the null guard the window path has)
Jess Jin (Jira)
-
[jira] [Resolved] (KAFKA-20915) Unneeded app thread wakeup when a fetch already in flight and nothing has changed in AsyncConsumer
Lianet Magrans (Jira)
-
[jira] [Created] (KAFKA-20921) ScramImage and ScramCredentialData are not deeply immutable
GiminKim (Jira)
-
[jira] [Created] (KAFKA-20920) Document new group coordinator executor metrics
Sean Quah (Jira)
-
[jira] [Created] (KAFKA-20919) Document KIP-1301 metrics changes
Sean Quah (Jira)
-
[jira] [Resolved] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20918) Add an example of RebalanceConsumer usage to the example module
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20917) Improve RecordAccumulator.ready performance
Xi Wang (Jira)
-
[jira] [Created] (KAFKA-20916) message protocol document missing new control record types
Jun Rao (Jira)
-
[jira] [Resolved] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20915) Unneeded app thread wakeup when a fetch already in flight and nothing has changed in AsyncConsumer
Lianet Magrans (Jira)
-
[jira] [Created] (KAFKA-20914) KafkaRaftClient does not clear append/fetch purgatories when a leader transitions to Resigned or Unattached
Anjaneya Gupta (Jira)
-
[jira] [Created] (KAFKA-20913) KafkaRaftClient#appendBatch reads a recycled batch buffer in its async commit callback, producing an incorrect appendTimestamp for committed batches
Anjaneya Gupta (Jira)
-
[jira] [Created] (KAFKA-20912) Unhappy paths for non-replaying writes lead to divergence between in-memory state and log
Sean Quah (Jira)
-
[jira] [Created] (KAFKA-20911) CorruptRecordException: Found record size 0 smaller than minimum record overhead
Santosh Kumar Sahu (Jira)
-
[jira] [Created] (KAFKA-20910) alterShareGroupOffsets impl in GroupCoordinatorService does not follow the KIP-932 spec.
Sushant Mahajan (Jira)
-
[PR Review Request] KAFKA-20834: Add unit test for Bytes.toString()
이주호
-
[jira] [Created] (KAFKA-20909) Consider bumping the consumer group epoch when a member's rack ID changes
sanghyeok An (Jira)
-
[jira] [Created] (KAFKA-20908) Consider exposing RACK-ID in kafka-share-groups.sh
sanghyeok An (Jira)
-
[jira] [Created] (KAFKA-20907) Remove deprecated 9-arg StreamsGroupDescription constructor
Lucy Liu (Jira)
-
[jira] [Created] (KAFKA-20906) Remove deprecated ValueJoinerWithKey overloads for stream-globalTable joins
Lucy Liu (Jira)
-
[jira] [Created] (KAFKA-20905) Remove deprecated headerless StreamPartitioner#partitions method
Lucy Liu (Jira)
-
[jira] [Created] (KAFKA-20904) AsyncKafkaConsumer is higher than expected CPU usage
Evan Zhou (Jira)
-
[jira] [Created] (KAFKA-20903) Revert public API changes from KIP-1238
Matthias J. Sax (Jira)
-
[DISCUSS] KIP-789: Use localhost:9092 as default bootstrap-server/broker-list in client tools.
ziming deng
-
[jira] [Resolved] (KAFKA-20816) Add CIDR support also into Authorizer.authorizeByResourceType
Mickael Maison (Jira)
-
[PR] Bump npm-check-updates from 22.2.9 to 23.0.1 [kafka-site]
via GitHub
-
[jira] [Created] (KAFKA-20902) Streams metered stores: oldest-iterator-open-since-ms can be wrong when two iterators open in the same millisecond
Jess Jin (Jira)
-
[jira] [Created] (KAFKA-20901) [KRaft] cordoned.log.dirs is accepted but not enforced when log.dirs uses a relative path
Apple Min (Jira)
-
[jira] [Resolved] (KAFKA-19839) Native-image (dockerimage) does not work with compression.type=zstd
Chia-Ping Tsai (Jira)
-
[DISCUSS] KIP-1095 Kafka Canary Isolation
Chen Zhifeng
-
[jira] [Created] (KAFKA-20900) docker_sanity_test.py should not ignore "Error" count
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20874) SslFactory not closed after extracting SSLSocketFactory
Luke Chen (Jira)
-
[jira] [Created] (KAFKA-20899) StickyTaskAssignor not sticky for standby tasks
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20898) PushTelemetry sets terminating flag on validation failure, permanently locking out client instance
Ken Huang (Jira)
-
[jira] [Created] (KAFKA-20897) KIP-1095: Kafka Canary Isolation
Zhifeng Chen (Jira)
-
[jira] [Resolved] (KAFKA-20744) Add back `rack.aware.assignment.tags` config
Ziyun Fu (Jira)
-
[jira] [Created] (KAFKA-20896) avoid epoch bump when adding a new config to the assignor
Ziyun Fu (Jira)
-
[jira] [Resolved] (KAFKA-18628) Deprecate broker.id
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20895) Different controller election behavior depending on node count
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20894) StreamsGroupDescription.toString throws NullPointerException when authorized operations are omitted
GiminKim (Jira)
-
[jira] [Created] (KAFKA-20893) KafkaStreams incorrectly reports task-offsets (ie state) for non-existing (previously owned) in-memory stores to the task assignor
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20892) SimpleHeaderConverter infers a string header as a number if it starts with a digit
Yuriy Badalyantc (Jira)
-
[jira] [Resolved] (KAFKA-20868) Add warmup tasks to IQ metadata
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20501) Integration tests for IQv1 transaction isolation
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20891) Remove unused "streams" protocol configs
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20503) Integration tests for transaction buffering
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-20504) Update state wipe tests
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-18157) Consider UnsupportedVersionException child class to represent the case of unsupported fields
TengYao Chi (Jira)
-
[DISCUSS] KIP-1370: Include Instance and Rack IDs in kafka-streams-groups.sh Member Output
Sanghyeok An
-
[jira] [Created] (KAFKA-20890) KRaft broker startup can fail to restore persisted dynamic broker configs when the local metadata snapshot is missing or stale
Tamas Kornai (Jira)
-
[jira] [Created] (KAFKA-20889) Consider rejecting empty group.instance.id values in Kafka Streams
sanghyeok An (Jira)
-
[jira] [Resolved] (KAFKA-20395) Support unregistering controllers
Jun Rao (Jira)
-
Hackathon task list needed - 10 weeks out
Bowen, Rich
-
[jira] [Resolved] (KAFKA-20215) add integration test for cordoning folders
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20888) Expose Streams group member rack IDs in kafka-streams-groups.sh
sanghyeok An (Jira)
-
[jira] [Created] (KAFKA-20887) IQ metadata is incomplete during "streams" protocol rebalances, causing incorrect IQ results
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20886) Missing `application.server` configuration silently breaks IQ key routing ("classic" protocol)
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20885) Incorrect IQ metadata in "streams" protocol
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20884) Consider kafka-streams-groups.sh supporting classic streams application.
sanghyeok An (Jira)
-
[jira] [Created] (KAFKA-20883) Consider exposing instance ID for the streams group.
sanghyeok An (Jira)
-
[DISCUSS] KIP-1318 (MCP Server for Apache Kafka): reference implementation available for review
vaquar khan
-
[jira] [Resolved] (KAFKA-13716) add tests for `DeleteRecordsCommand` class
Chia-Ping Tsai (Jira)
-
[Please provide GA workflow runs / `ci-approved` label] Gradle build releated PR's
Dejan Stojadinović
-
[jira] [Created] (KAFKA-20882) Reduce build time: use lazy creation for Gradle tasks (i.e. use `tasks.register` instead of `task` or `tasks.create`)
Jira
-
[jira] [Created] (KAFKA-20881) System tests fail to load connect-file plugin due to javadoc.jar conflict
Chia-Ping Tsai (Jira)
-
[Please provide GA workflow runs / `ci-approved` label] Gradle-related PRs: KAFKA-20103 / KAFKA-20851 / KAFKA-20862
Dejan Stojadinović
-
[jira] [Resolved] (KAFKA-20553) Eliminate the dependencies on "sourceSets.test.output"
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20880) Consider to address inconsistency in `StandbyUpdateListener` API
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSupsended
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20878) UnsupportedOperationException: This task is read-only during unclean shutdown
Nikita Shupletsov (Jira)
-
[jira] [Created] (KAFKA-20877) Streams task-level restore-rate and update-rate incorrect
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20876) Windowed restore optimisation gives up when `endOffset-1` is a transaction control record
Alan Lau (Jira)
-
[jira] [Created] (KAFKA-20875) Headers store adapters bypass the `WrappedStateStore` chain
Alan Lau (Jira)
-
[jira] [Created] (KAFKA-20874) RESOURCE_LEAK: SslFactory not closed after extracting SSLSocketFactory
Federico Valeri (Jira)
-
[jira] [Created] (KAFKA-20873) KafkaStreams.removeStreamThread can deadlock with a concurrent REPLACE_THREAD uncaught-exception handler
TengYao Chi (Jira)
-
[jira] [Resolved] (KAFKA-20779) followup review on the merged KIP-1265 PR
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20872) Integrate api-checker module into CI
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20871) Upgrade Jetty 12.0.34 dependencies in Kafka to address multiple security vulnerabilities
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20871) Upgrade Jetty 12.0.34 dependencies in Kafka to address multiple security vulnerabilities
Mangesh Dushman (Jira)
-
[PR] MINOR: Add technical blog post on gateway-to-Kafka event delivery [kafka-site]
via GitHub
-
Re: [DISCUSS] KIP-1232: Deprecate broker.id config
Ming-Yen Chung
-
[jira] [Created] (KAFKA-20870) Fix owned-task reports in StreamsGroupHeartbeat
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20869) KafkaStreams#addStreamsThread crashed global-task-only client
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20868) Consider to add warmup tasks to IQ metadata
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20867) Upgrade RocksDB dependency from 10.1.3 to 10.10.1
Lucy Liu (Jira)
-
[jira] [Created] (KAFKA-20866) Remove incremental-only fields from RecordAppendResult
Lianet Magrans (Jira)
-
[jira] [Created] (KAFKA-20865) Add check so voters cannot be unregistered
Kevin Wu (Jira)
-
[jira] [Created] (KAFKA-20864) Fix to avoid potential early batch close on pool exhausted if race happens
Lianet Magrans (Jira)
-
[jira] [Created] (KAFKA-20863) Add producer accumulator append benchmark
Lianet Magrans (Jira)
-
[jira] [Resolved] (KAFKA-19298) Move RuntimeLoggerManager to server module
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20862) Update gradle versions plugin in order to resolve issues with dependencies resolution
Jira
-
[jira] [Resolved] (KAFKA-20736) Improve leadership change handling in ShareConsumer
Andrew Schofield (Jira)
-
[jira] [Resolved] (KAFKA-20683) Add broker side custom assignors for "streams" groups
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-20790) Promote streams assignor API to public module
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20861) Kafka Streams should handle corrupted assignment pro-actively
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20860) Broken error handling in the async consumer background thread
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable
TengYao Chi (Jira)
-
[jira] [Created] (KAFKA-20859) Reduce per-append record sizing cost in the producer incremental strategy
Lianet Magrans (Jira)
-
[jira] [Resolved] (KAFKA-20843) Custom consumer group assignors may silently use duplicate or built-in assignor names
Ziyun Fu (Jira)
-
[DISCUSS] KIP-1354: Single purpose TLS extended key usages (EKU) support
Kondrát Bertalan