dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Resolved] (KAFKA-16991) Flaky Test org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState
Bill Bejeck (Jira)
[PR] test 2: trying again [kafka-merge-queue-sandbox]
via GitHub
[PR] Adding TEST file [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] Adding TEST file [kafka-merge-queue-sandbox]
via GitHub
[PR] Adding test file [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] Adding test file [kafka-merge-queue-sandbox]
via GitHub
[PR] Adding test file [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] Adding test file [kafka-merge-queue-sandbox]
via GitHub
[jira] [Created] (KAFKA-17072) Document broker decommissioning process with KRaft
Mickael Maison (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3071
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #61
Apache Jenkins Server
[jira] [Created] (KAFKA-17071) SharePartition - Add more unit tests
Abhinav Dixit (Jira)
[jira] [Resolved] (KAFKA-17026) Implement updateCacheAndOffsets functionality on LSO movement
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-17070) perf: consider to use ByteBufferOutputstream to append records
Luke Chen (Jira)
[jira] [Created] (KAFKA-17069) Remote copy throttle metrics
Abhijeet Kumar (Jira)
[jira] [Resolved] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package
David Jacot (Jira)
[jira] [Created] (KAFKA-17068) Failed to modify controller IP under Raft mode
Jianbin Chen (Jira)
[jira] [Reopened] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks
Chris Egerton (Jira)
[jira] [Resolved] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks
Chris Egerton (Jira)
[jira] [Created] (KAFKA-17067) Fix the transition to CandidateState
Jira
[jira] [Created] (KAFKA-17066) New consumer updateFetchPositions should perform all operations in background thread
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-17032) NioEchoServer should generate meaningful id instead of incremential number
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16550) add integration test for LogDirsCommand
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17051) ApiKeys#toHtml should exclude the APIs having unstable latest version
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-3346) Rename "Mode" to "SslMode"
Chia-Ping Tsai (Jira)
[PR] Adding feature A [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] Adding feature A [kafka-merge-queue-sandbox]
via GitHub
[jira] [Created] (KAFKA-17065) Consider caching the re-grouped data in session
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16255) AsyncKafkaConsumer should not use partition.assignment.strategy
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17064) New consumer assign should update assignment in background thread
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-17050) Revert group.version for 3.8 and 3.9
David Jacot (Jira)
[jira] [Created] (KAFKA-17063) Allow exporting SCRAM credentials
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-17062) RemoteLogManager - RemoteStorageException causes data loss
Guillaume Mallet (Jira)
[jira] [Created] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster
Haruki Okada (Jira)
[jira] [Resolved] (KAFKA-16756) Implement max delivery count functionality in SharePartition
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-15727) KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest
Abhinav Dixit (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3067
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #3068
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3069
Apache Jenkins Server
[DISCUSS] - KIP-1064: Upgrade slf4j to 2.x
Muralidhar Basani
[jira] [Created] (KAFKA-17060) Rename LegacyKafkaConsumer to ClassicKafkaConsumer
Kirk True (Jira)
[jira] [Resolved] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts
Bruno Cadonna (Jira)
[jira] [Created] (KAFKA-17059) Remove `dynamicConfigOverride` from KafkaConfig
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16909) Refactor GroupCoordinatorConfig with AbstractConfig
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17046) Upgrade netty version to 4.1.111.Final
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17058) Extend CoordinatorRuntime to support non-atomic writes
David Jacot (Jira)
[ANNOUNCE] Apache Kafka 3.7.1
Igor Soarez
Re: [ANNOUNCE] Apache Kafka 3.7.1
Mickael Maison
Re: [ANNOUNCE] Apache Kafka 3.7.1
Luke Chen
Re: [ANNOUNCE] Apache Kafka 3.7.1
Chia-Ping Tsai
Re: [ANNOUNCE] Apache Kafka 3.7.1
Igor Soarez
Re: [ANNOUNCE] Apache Kafka 3.7.1
Manikumar
Re: [ANNOUNCE] Apache Kafka 3.7.1
Igor Soarez
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3065
Apache Jenkins Server
[DISCUSS] KIP-1065: Add "retry" return-option to ProductionExceptionHandler
Matthias J. Sax
Re: [DISCUSS] KIP-1065: Add "retry" return-option to ProductionExceptionHandler
Sophie Blee-Goldman
Re: [DISCUSS] KIP-1065: Add "retry" return-option to ProductionExceptionHandler
jiang dou
[jira] [Created] (KAFKA-17057) Add "retry" option to ProductionExceptionHandler
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-16508) Infinite loop if output topic does not exisit
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-17056) Convert producer state metadata schemas to use generated protocol
Chia-Ping Tsai (Jira)
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #3063
Apache Jenkins Server
[jira] [Resolved] (KAFKA-14118) Generate and persist storage uuiid
Jira
[jira] [Resolved] (KAFKA-14116) Update and add all of the Kafka Message Schemas
Jira
[jira] [Resolved] (KAFKA-14113) KIP-856: KRaft Disk Failure Recovery
Jira
[jira] [Created] (KAFKA-17055) Use random replica ids in KafkaRaftClientTest and KafkaRaftClientSnapshotTest
Jira
[jira] [Created] (KAFKA-17054) test
Xuze Yang (Jira)
[jira] [Created] (KAFKA-17053) Restructure build.gradle to configure publishing last
Greg Harris (Jira)
[jira] [Created] (KAFKA-17052) Downgrade ShadowJavaPlugin to 8.1.3 to avoid publishing classifier bug
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder
Brenden DeLuna (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #185
Apache Jenkins Server
[VOTE] KIP-1054: Support external schemas in JSONConverter
Priyanka K U
[jira] [Resolved] (KAFKA-17022) Fix error-prone in KafkaApis#handleFetchRequest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17051) ApiKeys#toHtml should exclude the APIs having unstable latest version
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16781) Expose advertised.listeners in controller node
Luke Chen (Jira)
[jira] [Created] (KAFKA-17050) Revert group.version for 3.8 and 3.9
Justine Olshan (Jira)
[jira] [Created] (KAFKA-17049) unbalanced connectors
yazgoo (Jira)
[jira] [Created] (KAFKA-17048) Document how to use KIP-853
Jira
[jira] [Resolved] (KAFKA-17028) FindCoordinator v6 initial implementation
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package
Apoorv Mittal (Jira)
[DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
Omnia Ibrahim
Re: [DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
Andrew Schofield
Re: [DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
Omnia Ibrahim
Re: [DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
Andrew Schofield
Re: [DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
David Jacot
Re: [DISCUSS] KIP-1062: Introduce Pagination for some requests used by Admin API
Omnia Ibrahim
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3053
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3054
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3055
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3056
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3057
Apache Jenkins Server
[jira] [Resolved] (KAFKA-12910) Configure automatic formatter for org.apache.kafka.streams.state
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-10787) Introduce an import order in Java sources
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-12911) Configure automatic formatter for org.apache.kafka.streams.processor
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group
David Jacot (Jira)
[jira] [Resolved] (KAFKA-16754) Implement release acquired records functionality in SharePartition
Abhinav Dixit (Jira)
[jira] [Resolved] (KAFKA-14109) Clean up JUnit 4 test infrastructure
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-7342) Migrate streams modules to JUnit 5
Mickael Maison (Jira)
[jira] [Created] (KAFKA-17046) Upgrade netty version to 4.1.111.Final
XiDuo You (Jira)
[jira] [Created] (KAFKA-17045) Move MetadataLogConfig from kafka to kafka.raft
XiDuo You (Jira)
[jira] [Resolved] (KAFKA-15623) Migrate remaining tests in streams module to JUnit 5
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-7339) Migrate from JUnit 4 to JUnit 5
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16751) Implement release acquired records in SharePartitionManager
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-17044) Connector worker does not shutdown until start completes
Bhagyashree (Jira)
Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #192
Apache Jenkins Server
[jira] [Created] (KAFKA-17043) Strictly Uniform Sticky partition strategy leads to slow handling of command events
Timur (Jira)
[jira] [Created] (KAFKA-17042) the migration docs should remind users to set "broker.id.generation.enable" when adding broker.id
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17041) Add pagination when describe large set of metadata via Admin API
Omnia Ibrahim (Jira)
[jira] [Resolved] (KAFKA-17003) Implement SharePartitionManager close functionality
Abhinav Dixit (Jira)
[jira] [Resolved] (KAFKA-15724) KRaft support in OffsetFetchRequestTest
Shivsundar R (Jira)
How are we feeling about recent trends in distributed backend messaging?
Liam Gryphon
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #3049
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3050
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3051
Apache Jenkins Server
[DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Justine Olshan
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Jun Rao
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Jun Rao
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Jun Rao
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
David Jacot
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Colin McCabe
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
Chia-Ping Tsai
Re: [DISCUSS] KIP-1014: Managing Unstable Features in Apache Kafka
David Jacot
[jira] [Resolved] (KAFKA-17034) Tweak some descriptions in `FeatureUpdate`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17040) Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer
Kirk True (Jira)
[jira] [Resolved] (KAFKA-16949) System test test_dynamic_logging in connect_distributed_test is failing
Chris Egerton (Jira)
[jira] [Resolved] (KAFKA-15466) Add KIP-919 support for some admin APIs
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17039) KIP-919 supports for `describeDelegationToken`, `describeUserScramCredentials` and `unregisterBroker`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17038) KIP-919 supports for `alterPartitionReassignments` and `listPartitionReassignments`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17037) KIP-919 supports for `describeClientQuotas` and `alterClientQuotas`
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17036) KIP-919 supports for `createAcls`, `deleteAcls`, `describeAcls`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16650) add integration test for Admin#abortTransaction
Chia-Ping Tsai (Jira)
[VOTE] KIP-1059: Enable the Producer flush() method to clear the latest send() error
Alieh Saeedi
Re: [VOTE] KIP-1059: Enable the Producer flush() method to clear the latest send() error
Andrew Schofield
Re: [VOTE] KIP-1059: Enable the Producer flush() method to clear the latest send() error
Matthias J. Sax
[jira] [Resolved] (KAFKA-10413) rebalancing leads to unevenly balanced connectors
Sagar Rao (Jira)
[jira] [Created] (KAFKA-17035) Add debug log to retention cleanupLogs method to help troubleshoot issues
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-16755) Implement lock timeout functionality in SharePartition
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-17034) Tweak some descriptions in `FeatureUpdate`
Chia-Ping Tsai (Jira)
[jira] [Reopened] (KAFKA-17015) ContextualRecord#hashCode()、ProcessorRecordContext#hashCode() Should not be deprecated and throw an exception
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17015) ContextualRecord#hashCode()、ProcessorRecordContext#hashCode() Should not be deprecated and throw an exception
dujian0068 (Jira)
[jira] [Resolved] (KAFKA-17015) ContextualRecord#hashCode()、ProcessorRecordContext#hashCode() Should not be deprecated and throw an exception
Chia-Ping Tsai (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3045
Apache Jenkins Server
[jira] [Created] (KAFKA-17033) Consider replacing the directory id Optional<Uuid> with just Uuid
Jira
[jira] [Resolved] (KAFKA-16965) Add a "root cause" exception as a nested exception to TimeoutException for Producer
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-17032) NioEchoServer should generate meaningful id instead of incremential number
Chia-Ping Tsai (Jira)
[jira] [Reopened] (KAFKA-16990) Unrecognised flag passed to kafka-storage.sh in system test
Justine Olshan (Jira)
[jira] [Created] (KAFKA-17031) Make configurations public
Christo Lolov (Jira)
[jira] [Resolved] (KAFKA-16990) Unrecognised flag passed to kafka-storage.sh in system test
Justine Olshan (Jira)
[jira] [Resolved] (KAFKA-16990) Unrecognised flag passed to kafka-storage.sh in system test
Justine Olshan (Jira)
[jira] [Resolved] (KAFKA-17013) RequestManager#ConnectionState#toString() should use %s
Chia-Ping Tsai (Jira)
RE: Re:[DISCUSS] KIP-1009: Add Broker-level Throttle Configurations
Harry Fallows
[jira] [Created] (KAFKA-17030) Voters should not assume that the leader will send them BeginQuorumEpoch requests
Jira
[jira] [Created] (KAFKA-17029) SetSchemaMetadata smt throws DataException when avro schema is primitive type
Mark McDonald (Jira)
[jira] [Created] (KAFKA-17028) FindCoordinator v6 initial implementation
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-17004) MINOR: Remove extra synchronized blocks in SharePartitionManager
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-17027) Inconsistent casing in Selector metrics tags
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-16967) NioEchoServer fails to register connection and causes flaky failure
Chia-Ping Tsai (Jira)
[DISCUSS] KIP-1060: Expose advertised.listeners for KRaft controllers
Gantigmaa Selenge
Re: [DISCUSS] KIP-1060: Expose advertised.listeners for KRaft controllers
José Armando García Sancio
Re: [DISCUSS] KIP-1060: Expose advertised.listeners for KRaft controllers
Gantigmaa Selenge
Re: [DISCUSS] KIP-1060: Expose advertised.listeners for KRaft controllers
José Armando García Sancio
[jira] [Resolved] (KAFKA-16999) Integrate persister read API in Partition leader initilization
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-16749) Implement share fetch messages
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-16748) Implement share response handling in SharePartitionManager
Apoorv Mittal (Jira)
RE: Herder#requestTaskReconfiguration
talljhawkins
Re: Herder#requestTaskReconfiguration
Greg Harris
[jira] [Created] (KAFKA-17026) Implement updateCachedAndOffsets functionality on LSO movement
Abhinav Dixit (Jira)
[jira] [Reopened] (KAFKA-16551) add integration test for ClusterTool
Chia-Ping Tsai (Jira)
[DISCUSS] KIP-1061: Allow exporting SCRAM credentials
kafka
[jira] [Resolved] (KAFKA-16551) add integration test for ClusterTool
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16551) add integration test for ClusterTool
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16998) Fix warnings in our Github actions
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17025) KafkaThread and KafkaProducer expose method to set setUncaughtExceptionHandler
Hongshun Wang (Jira)
apply a jira account
周 正轲
Re: apply a jira account
Matthias J. Sax
回复: apply a jira account
zhou zhengke
Re: 回复: apply a jira account
Matthias J. Sax
[jira] [Resolved] (KAFKA-17009) Add unit test to query nonexistent replica by describeReplicaLogDirs
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17024) add integration test for TransactionsCommand
Chia-Ping Tsai (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #3040
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3041
Apache Jenkins Server
[jira] [Created] (KAFKA-17023) add PCollectionsImmutableMap to ConcurrentMapBenchmark
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17022) Fix error-prone in KafkaApis#handleFetchRequest
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-12227) Add method "Producer#send" to return CompletionStage instead of Future
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17021) Migrate AclCommandTest to new test infra
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-15713) KRaft support in SaslClientsWithInvalidCredentialsTest
Chia-Ping Tsai (Jira)
Enabling Retry for Meta Data Fetch
Yash Tailor
[jira] [Created] (KAFKA-17020) After enabling tiered storage, occasional residual logs are left in the replica
Jianbin Chen (Jira)
[jira] [Created] (KAFKA-17019) Producer TimeoutException should include root cause
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-17018) Metadata version 3.9 should return Fetch version 17
Jira
[jira] [Created] (KAFKA-17017) AsyncConsumer#unsubscribe does not clean the assigned partitions
Chia-Ping Tsai (Jira)
Re: [PR] Adding OREXES to powered-by section [kafka-site]
via GitHub
Re: [PR] Netstratum info updated [kafka-site]
via GitHub
Re: [PR] adding spitha on powered-by [kafka-site]
via GitHub
Re: [PR] adding spitha on powered-by [kafka-site]
via GitHub
Re: [PR] Update powered-by.html [kafka-site]
via GitHub
Earlier messages