dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: Request to Contribute to Apache Kafka
Matthias J. Sax
Getting Started: requesting permissions to contribute to Apache Kafka
Rich C.
Re: Getting Started: requesting permissions to contribute to Apache Kafka
Luke Chen
[jira] [Resolved] (KAFKA-17168) The logPrefix of RemoteLogReader/RemoteStorageThreadPool is not propagated correctly
Chia-Ping Tsai (Jira)
Wiki Kafka Kip access
Mason Chen
Re: Wiki Kafka Kip access
Luke Chen
Wiki Kafka Kip access
Sébastien Viale
Re: Wiki Kafka Kip access
Matthias J. Sax
[jira] [Resolved] (KAFKA-17082) Replace kafka.utils.LogCaptureAppender with org.apache.kafka.common.utils.LogCaptureAppender
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17153) KafkaMetricsGroup#newGauge should accept functional interface instead of `com.yammer.metrics.core.Gague`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17144) Retract v6 of ListGroups RPC added in error
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17152) Make sure zk session tracker gets down when closing embedded zk
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17172) add `@Tag("integration")` to `ClusterTest`, `ClusterTemplate`, and `ClusterTests`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17173) Move all quota getters from `KafkaConfig` to `QuotaConfigs`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17167) Moving the flush call inside the read lock when writing truncation
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17172) add `@Tag("integration")` to `ClusterTest`, `ClusterTemplate`, and `ClusterTests`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17171) Add test cases for `STATIC_BROKER_CONFIG`in kraft mode
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17170) Add test to ensure new consumer acks reconciled assignment even if first HB with ack lost
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17169) Add an EndpointsTest suite that test all of the public methods
Jira
[jira] [Resolved] (KAFKA-12877) Fix KRPC files with missing flexibleVersions annotation
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17132) Revisit testMissingOffsetNoResetPolicy for AsyncConsumer
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17121) junit-platform.properties files in published artifacts pollute the test classpath of consumers
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17168) The logPrefix of RemoteLogReader/RemoteStorageThreadPool is not propagated correctly
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17095) Fix the typo: CreateableTopicConfig -> CreatableTopicConfig
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17077) the node.id is inconsistent to broker.id when "broker.id.generation.enable=true"
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17122) Change the type of `clusterId` from `UUID` to `String`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17118) Remove StorageTool#buildMetadataProperties
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17167) Moving the flush call inside the read lock when writing truncation
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17166) Use `NoOpScheduler` to rewrite LogManagerTest#testLogRecoveryMetrics
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17165) Revisit LeaderEpochFileCache#writeToFileForTruncation
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17164) Consider to enforce application.server <server>:<port> format at config level
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-17163) Revisit testSubscriptionOnInvalidTopic for AsyncKafkaConsumer
Lianet Magrans (Jira)
Support Needed
MIMOUNI WAFAA
[jira] [Created] (KAFKA-17162) DefaultTaskManagerTest may leak AwaitingRunnable thread
Ao Li (Jira)
[jira] [Created] (KAFKA-17161) REST Jersey metric names are inconsistent
Doug Hoard (Jira)
[jira] [Created] (KAFKA-17160) Always import `mockito-inline` if the mockito version is 4.x
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17159) Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit
PoAn Yang (Jira)
[jira] [Resolved] (KAFKA-16975) The error message of creating `__cluster_metadata` should NOT be "Authorization failed"
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17142) Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics
Chia-Ping Tsai (Jira)
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 2.8 #1
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 3.0 #1
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 3.1 #1
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 3.5 #1
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 3.8 #1
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka PowerPC Daily » 3.6 #1
Apache Jenkins Server
[jira] [Resolved] (KAFKA-15773) Group protocol configuration should be validated
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17135) Add unit test for `ProducerStateManager#readSnapshot` and `ProducerStateManager#writeSnapshot`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17141) "DescribeTopicPartitions API is not supported" warning message confuses users
Chia-Ping Tsai (Jira)
[VOTE] 3.8.0 RC2
Josep Prat
Re: [kafka-clients] [VOTE] 3.8.0 RC2
Igor Soarez
Re: [VOTE] 3.8.0 RC2
Jakub Scholz
Re: [VOTE] 3.8.0 RC2
Chia-Ping Tsai
Re: [VOTE] 3.8.0 RC2
Josep Prat
[jira] [Created] (KAFKA-17158) Method 'cleanupLogs' can not delete old logSegements after invoking ALTER_REPLICA_LOG_DIRS
fujian.zfj (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3118
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3119
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3120
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3121
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #70
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #71
Apache Jenkins Server
[jira] [Resolved] (KAFKA-17150) Connect converter validation does not accept class aliases
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-17105) Unnecessary connector restarts after being newly created
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17157) Refactor mutability and state transitions in DistributedHerder
Greg Harris (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3116
Apache Jenkins Server
[jira] [Created] (KAFKA-17156) Metadata controller to provide the KafkaRaftClient with the broker's supported kraft.version
Jira
[jira] [Created] (KAFKA-17155) Redundant rebalances triggered after connector creation/deletion and task config updates
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17154) New consumer subscribe may join group without a call to consumer.poll
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-16853) Split RemoteLogManagerScheduledThreadPool
Abhijeet Kumar (Jira)
[jira] [Reopened] (KAFKA-16154) Make broker changes to return an offset for LATEST_TIERED_TIMESTAMP
Luke Chen (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3114
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16383) fix flaky test IdentityReplicationIntegrationTest.testReplicateFromLatest()
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17153) KafkaMetricsGroup#newGauge should accept functional interface instead of `com.yammer.metrics.core.Gague`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17152) Make sure zk session tracker gets down when closing embedded zk
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17151) Remove waitForCondition when detecting thread leak
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17150) Connect converter validation does not accept class aliases
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-17017) AsyncConsumer#unsubscribe does not clean the assigned partitions
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17149) Move ProducerStateManagerTest to storage module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17148) Kafka storage tool prints MetadataPropertiesEnsemble
Greg Harris (Jira)
[jira] [Created] (KAFKA-17147) Improve KRaft add voter handling to tolerate waiting for delayed operations
Jira
[jira] [Resolved] (KAFKA-17055) Use random replica ids in KafkaRaftClientTest and KafkaRaftClientSnapshotTest
Jira
[jira] [Resolved] (KAFKA-17145) Reinstate Utils.join() method in org.apache.kafka.common.utils
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17146) ZK to KRAFT migration stuck in pre-migration mode
Simone Brundu (Jira)
[jira] [Created] (KAFKA-17145) Reinstate Utils.join() method in org.apache.kafka.common.utils
Vikas Balani (Jira)
[jira] [Created] (KAFKA-17144) Retract v6 of ListGroups RPC added in error
Andrew Schofield (Jira)
Re: [PR] MINOR: document how we deal with advisories for dependencies [kafka-site]
via GitHub
Re: [PR] MINOR: document how we deal with advisories for dependencies [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes
Vinicius Vieira dos Santos (Jira)
[jira] [Resolved] (KAFKA-16730) Initial code for share-group consumer
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-17143) Error while deleting segments and java.nio.file.NoSuchFileException
Prem Kumar (Jira)
[PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
Re: [PR] Add blog post for 3.8 release [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-17133) add unit test to make sure `ConsumerRecords#recoreds` returns immutable object
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17073) Deprecate ReplicaVerificationTool in 3.9
Chia-Ping Tsai (Jira)
Re: [PR] MINOR: update docs to 3.8 [kafka-site]
via GitHub
[jira] [Resolved] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-16744) Add support for share group describe in KafkaApis
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-16750) Implement acknowledge API in SharePartitionManager
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-17142) Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3110
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3111
Apache Jenkins Server
[jira] [Created] (KAFKA-17141) "DescribeTopicPartitions API is not supported" warning message confuses users
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-14401) Connector/Tasks reading offsets can get stuck if underneath WorkThread dies
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17140) 'make tools' should check the version of tools
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17102) FetchRequest#forgottenTopics would return incorrect data
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3108
Apache Jenkins Server
Re: [DISCUSS] KIP-950: Tiered Storage Disablement
Jun Rao
Re: [DISCUSS] KIP-950: Tiered Storage Disablement
Christo Lolov
[VOTE] 3.8.0 RC1
Josep Prat
Re: [kafka-clients] [VOTE] 3.8.0 RC1
Igor Soarez
Re: [VOTE] 3.8.0 RC1
Jakub Scholz
Re: [VOTE] 3.8.0 RC1
Greg Harris
Re: [VOTE] 3.8.0 RC1
Josep Prat
Re: [VOTE] 3.8.0 RC1
Josep Prat
[jira] [Created] (KAFKA-17139) MirrorSourceTask will stop mirroring when get BufferUnderflowException
Yu Wang (Jira)
[jira] [Created] (KAFKA-17138) tiered storage with apache iceberg
yongzhi.shao (Jira)
[jira] [Resolved] (KAFKA-17097) Add replace.null.with.default configuration to ValueToKey and ReplaceField (KIP-1040)
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16661) add a lower `log.initial.task.delay.ms` value to integration test framework
Luke Chen (Jira)
[jira] [Created] (KAFKA-17137) Ensure Admin APIs are properly tested
Mickael Maison (Jira)
[jira] [Created] (KAFKA-17136) Added Documentation for Shell Methods
Arnav Dadarya (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3106
Apache Jenkins Server
[jira] [Resolved] (KAFKA-17129) Revisit FindCoordinatorResponse in KafkaConsumerTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17135) Add unit test for `ProducerStateManager#readSnapshot` and `ProducerStateManager#writeSnapshot`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17134) Restarting a server (same JVM) configured for OAUTHBEARER fails with RejectedExecutionException
Keith Wall (Jira)
[jira] [Resolved] (KAFKA-17110) Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17106) Enable KafkaConsumerTest#testFetchProgressWithMissingPartitionPosition for AsyncConsumer
Chia-Ping Tsai (Jira)
Proposal to Include Record Headers in ProducerInterceptor onAcknowledgement Method
Rich C.
Re: Proposal to Include Record Headers in ProducerInterceptor onAcknowledgement Method
Matthias J. Sax
Re: Proposal to Include Record Headers in ProducerInterceptor onAcknowledgement Method
Rich C.
Re: Proposal to Include Record Headers in ProducerInterceptor onAcknowledgement Method
Matthias J. Sax
Re: Proposal to Include Record Headers in ProducerInterceptor onAcknowledgement Method
Rich C.
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3101
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #3102
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3103
Apache Jenkins Server
[jira] [Created] (KAFKA-17133) add unit test to make sure `ConsumerRecords#recoreds` returns immutable object
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17132) Revisit testMissingOffsetNoResetPolicy for AsyncConsumer
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17131) Cleanup `ProcessorContext` an related interfaces
Matthias J. Sax (Jira)
Re: [DISCUSS] KIP-1043: Administration of groups
Lianet M.
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Lianet M.
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Apoorv Mittal
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Lianet M.
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Lucas Brutschy
Re: [DISCUSS] KIP-1043: Administration of groups
Lianet M.
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
David Jacot
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [DISCUSS] KIP-1043: Administration of groups
David Jacot
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
Re: [PR] Fix update email notifications [kafka-merge-queue-sandbox]
via GitHub
[jira] [Created] (KAFKA-17130) Connect workers do not properly ensure group membership before responding to health checks
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17129) Revisit FindCoordinatorResponse in KafkaConsumerTest
PoAn Yang (Jira)
[jira] [Created] (KAFKA-17128) Make node.id immutable after removing Zookeeper
TengYao Chi (Jira)
[jira] [Resolved] (KAFKA-17096) Fix kafka_log4j_appender.py
Chia-Ping Tsai (Jira)
[VOTE] 3.8.0 RC0
Josep Prat
Re: [VOTE] 3.8.0 RC0
Jakub Scholz
Re: [VOTE] 3.8.0 RC0
Josep Prat
Re: [VOTE] 3.8.0 RC0
Josep Prat
Re: [VOTE] 3.8.0 RC0
Mickael Maison
Re: [VOTE] 3.8.0 RC0
Luke Chen
Re: [VOTE] 3.8.0 RC0
Mickael Maison
Re: [VOTE] 3.8.0 RC0
Luke Chen
[jira] [Created] (KAFKA-17127) Add check for whether the requested partition exists or not in Share Fetch request
Chirag Wadhwa (Jira)
Earlier messages
Later messages