dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[VOTE] KIP-1036: Extend RecordDeserializationException exception
Frédérik Rouleau
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Andrew Schofield
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Federico Valeri
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Matthias J. Sax
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Sophie Blee-Goldman
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Bill Bejeck
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Kirk True
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Bruno Cadonna
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Frédérik Rouleau
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Lucas Brutschy
Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception
Frédérik Rouleau
[jira] [Created] (KAFKA-16646) Consider only running the CVE scanner action on apache/kafka and not in forks
Mickael Maison (Jira)
[jira] [Created] (KAFKA-16645) CVEs in 3.7.0 docker image
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-10859) add @Test annotation to FileStreamSourceTaskTest.testInvalidFile and reduce the loop count to speedup the test
Chia-Ping Tsai (Jira)
Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #149
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #150
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #151
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.7 #152
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #153
Apache Jenkins Server
[jira] [Created] (KAFKA-16644) FK join emit duplicate tombstone on left-side delete
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-16467) Add README to docs folder
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-16627) Remove ClusterConfig parameter in BeforeEach and AfterEach
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-15897) Flaky Test: testWrongIncarnationId() – kafka.server.ControllerRegistrationManagerTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16643) Add ModifierOrder checkstyle rule
Greg Harris (Jira)
Wiki account sign-up
Matthias J. Sax
[jira] [Created] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists
Kirk True (Jira)
[jira] [Created] (KAFKA-16641) MM2 offset translation should interpolate between sparse OffsetSyncs
Greg Harris (Jira)
[jira] [Resolved] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close
Calvin Liu (Jira)
[jira] [Resolved] (KAFKA-16460) New consumer times out consuming records in consumer_test.py system test
Kirk True (Jira)
Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure
Federico Valeri
Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure
Philip Nee
[jira] [Resolved] (KAFKA-16563) migration to KRaft hanging after MigrationClientException
Luke Chen (Jira)
Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client
Rajini Sivaram
Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client
Federico Valeri
Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client
Philip Nee
Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client
José Armando García Sancio
[jira] [Created] (KAFKA-16640) Replace TestUtils#resource by scala.util.Using
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16638) Align the naming convention for config and default variables in *Config classes
Omnia Ibrahim (Jira)
[jira] [Created] (KAFKA-16637) KIP-848 does not work well
sanghyeok An (Jira)
[jira] [Resolved] (KAFKA-16560) Refactor/cleanup BrokerNode/ControllerNode/ClusterConfig
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16636) Flaky test - testStickyTaskAssignorLargePartitionCount – org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16635) Flaky test "shouldThrottleOldSegments(String).quorum=kraft" – kafka.server.ReplicationQuotasTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16634) Flaky test - testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16633) Flaky test - testDescribeExistingGroupWithNoMembers(String, String).quorum=kraft+kip848.groupProtocol=consumer – org.apache.kafka.tools.consumer.group.DescribeConsumerGroupTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16632) Flaky test testDeleteOffsetsOfStableConsumerGroupWithTopicPartition [1] Type=Raft-Isolated, MetadataVersion=3.8-IV0, Security=PLAINTEXT – org.apache.kafka.tools.consumer.group.DeleteOffsetsConsumerGroupCommandIntegrationTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16631) Flaky test - testDeleteOffsetsOfStableConsumerGroupWithTopicOnly [1] Type=Raft-Isolated, MetadataVersion=3.8-IV0, Security=PLAINTEXT – org.apache.kafka.tools.consumer.group.DeleteOffsetsConsumerGroupCommandIntegrationTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Igor Soarez (Jira)
[jira] [Resolved] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16629) add broker-related tests to ConfigCommandIntegrationTest
Chia-Ping Tsai (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2850
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2851
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2852
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2853
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2854
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2855
Apache Jenkins Server
[jira] [Created] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-16609) Update parse_describe_topic to support new topic describe output
Kirk True (Jira)
[VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Damien Gasparina
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Bruno Cadonna
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Bill Bejeck
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Sophie Blee-Goldman
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Matthias J. Sax
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Lianet M.
Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Damien Gasparina
[VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing
Loic Greffier
[jira] [Resolved] (KAFKA-16621) Alter MirrorSourceConnector offsets dont work
yuzhou (Jira)
[jira] [Created] (KAFKA-16627) Remove ClusterConfig parameter in BeforeEach and AfterEach
Kuan Po Tseng (Jira)
[VOTE] KIP-1023: Follower fetch from tiered offset
Abhijeet Kumar
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Kamal Chandraprakash
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Omnia Ibrahim
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Luke Chen
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Christo Lolov
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Jun Rao
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Satish Duggana
Re: [VOTE] KIP-1023: Follower fetch from tiered offset
Abhijeet Kumar
[jira] [Created] (KAFKA-16626) Uuid to String for subscribed topic names in assignment spec
Ritika Reddy (Jira)
[jira] [Created] (KAFKA-16625) Reverse Lookup Partition to Member in Assignors
Ritika Reddy (Jira)
[jira] [Created] (KAFKA-16624) Don't generate useless PartitionChangeRecord on older MV
Colin McCabe (Jira)
[jira] [Created] (KAFKA-16623) KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned
Kirk True (Jira)
[jira] [Created] (KAFKA-16622) Mirromaker2 first Checkpoint not emitted until consumer group fully catches up once
Edoardo Comar (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2845
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2846
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2847
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16568) Add JMH Benchmarks for assignor performance testing
David Jacot (Jira)
[PR] MINOR: remove reference to IRC channel [kafka-site]
via GitHub
Re: [PR] MINOR: remove reference to IRC channel [kafka-site]
via GitHub
[jira] [Created] (KAFKA-16621) Alter MirrorSourceConnector offsets dont work
yuzhou (Jira)
[jira] [Created] (KAFKA-16620) Kraft quorum cannot be formed if all controllers are restarted at the same time
Gantigmaa Selenge (Jira)
[jira] [Created] (KAFKA-16619) Unnecessary warning : "Loaded ZK migration state of NONE"
Jira
Re: [VOTE] KIP-910: Update Source offsets for Source Connectors without producing records
Sagar
Re: [VOTE] KIP-910: Update Source offsets for Source Connectors without producing records
Антон Левчук
Confluence edit access
Claude Warren
Re: Confluence edit access
Matthias J. Sax
Re: Confluence edit access
Claude Warren
Re: Confluence edit access
Matthias J. Sax
[DISCUSS] Apache Kafka 3.7.1 release
Igor Soarez
Re: [DISCUSS] Apache Kafka 3.7.1 release
Mickael Maison
Re: [DISCUSS] Apache Kafka 3.7.1 release
Luke Chen
Re: [DISCUSS] Apache Kafka 3.7.1 release
Lucas Brutschy
Re: [DISCUSS] Apache Kafka 3.7.1 release
Chia-Ping Tsai
Re: [DISCUSS] Apache Kafka 3.7.1 release
Justine Olshan
Re: [DISCUSS] Apache Kafka 3.7.1 release
Justine Olshan
Re: [DISCUSS] Apache Kafka 3.7.1 release
Igor Soarez
Re: [DISCUSS] Apache Kafka 3.7.1 release
Justine Olshan
[jira] [Created] (KAFKA-16618) Update the RPC for ConsumerGroupHeartbeatRequest and ConsumerGroupHeartbeatResponse
Phuc Hong Tran (Jira)
Permissions to contribute to Apache Kafka
Rajdeep Sahoo
Re: Permissions to contribute to Apache Kafka
Mickael Maison
[jira] [Resolved] (KAFKA-16610) Replace "Map#entrySet#forEach" by "Map#forEach"
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16617) Add KRaft info for the `advertised.listeners` doc description
Luke Chen (Jira)
[jira] [Created] (KAFKA-16616) refactor mergeWith in MetadataSnapshot
Alyssa Huang (Jira)
[jira] [Created] (KAFKA-16615) JoinGroup API for upgrading ConsumerGroup
Dongnuo Lyu (Jira)
[jira] [Created] (KAFKA-16614) Disallow `@ClusterTemplate("")`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16613) Remove TestUtils#subscribeAndWaitForRecords
Chia-Ping Tsai (Jira)
[ANNOUNCE] New committer: Igor Soarez
Colin McCabe
Re: [ANNOUNCE] New committer: Igor Soarez
Mickael Maison
Re: [ANNOUNCE] New committer: Igor Soarez
Chia-Ping Tsai
Re: [ANNOUNCE] New committer: Igor Soarez
Tom Bentley
Re: [ANNOUNCE] New committer: Igor Soarez
Gaurav Narula
Re: [ANNOUNCE] New committer: Igor Soarez
Bill Bejeck
Re: [ANNOUNCE] New committer: Igor Soarez
Matthias J. Sax
Re: [ANNOUNCE] New committer: Igor Soarez
Luke Chen
Re: [ANNOUNCE] New committer: Igor Soarez
Kamal Chandraprakash
Re: [ANNOUNCE] New committer: Igor Soarez
Yash Mayya
Re: [ANNOUNCE] New committer: Igor Soarez
Bruno Cadonna
Re: [ANNOUNCE] New committer: Igor Soarez
Viktor Somogyi-Vass
Re: [ANNOUNCE] New committer: Igor Soarez
Randall Hauch
Re: [ANNOUNCE] New committer: Igor Soarez
Igor Soarez
Re: [ANNOUNCE] New committer: Igor Soarez
Christo Lolov
Re: [ANNOUNCE] New committer: Igor Soarez
ziming deng
Re: [ANNOUNCE] New committer: Igor Soarez
Guozhang Wang
[jira] [Reopened] (KAFKA-15743) KRaft support in ReplicationQuotasTest
Proven Provenzano (Jira)
[jira] [Reopened] (KAFKA-16606) JBOD support in KRaft does not seem to be gated by the metadata version
Igor Soarez (Jira)
[jira] [Resolved] (KAFKA-16592) ConfigKey constructor update can break clients using it
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16613) Remove TestUtils#subscribeAndWaitForRecords
PoAn Yang (Jira)
[jira] [Created] (KAFKA-16612) Talking to controllers via AdminClient requires reconfiguring controller listener
Gantigmaa Selenge (Jira)
[jira] [Resolved] (KAFKA-16483) Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16611) Consider adding test name to "client.id" of Admin in testing
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16610) Replace "Map#entrySet#forEach" by "Map#forEach"
Chia-Ping Tsai (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2840
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2841
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2842
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16424) truncated logs will be left undeleted after alter dir completion
Luke Chen (Jira)
[jira] [Created] (KAFKA-16609) Update parse_describe_topic to support new topic describe output
Kirk True (Jira)
[PR] MINOR: Add Igor to committers [kafka-site]
via GitHub
Re: [PR] MINOR: Add Igor to committers [kafka-site]
via GitHub
Re: [PR] MINOR: Add Igor to committers [kafka-site]
via GitHub
Re: [PR] MINOR: Add Igor to committers [kafka-site]
via GitHub
[jira] [Created] (KAFKA-16608) AsyncKafkaConsumer doesn't honour interrupted thread status on KafkaConsumer.poll(Duration)
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-16462) New consumer fails with timeout in security_test.py system test
Kirk True (Jira)
[jira] [Resolved] (KAFKA-16464) New consumer fails with timeout in replication_replica_failure_test.py system test
Kirk True (Jira)
[jira] [Created] (KAFKA-16607) Update the KIP and metrics implementation to include the new state
Jira
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #144
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #145
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #146
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16606) JBOD support in KRaft does not seem to be gated by the metadata version
Jakub Scholz (Jira)
[jira] [Created] (KAFKA-16606) JBOD support in KRaft does not seem to be gated by the metadata version
Jakub Scholz (Jira)
[jira] [Created] (KAFKA-16605) Fix the flaky LogCleanerParameterizedIntegrationTest
Kamal Chandraprakash (Jira)
[jira] [Created] (KAFKA-16604) Deprecate ConfigDef.ConfigKey constructor from public APIs
Sagar Rao (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2837
Apache Jenkins Server
[jira] [Created] (KAFKA-16603) Data loss when kafka connect sending data to Kafka
Anil Dasari (Jira)
[jira] [Created] (KAFKA-16602) Flaky test – org.apache.kafka.controller.QuorumControllerTest.testBootstrapZkMigrationRecord()
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16601) Flaky test – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest.testClosingQuorumControllerClosesMetrics()
Igor Soarez (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #142
Apache Jenkins Server
[jira] [Created] (KAFKA-16600) Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close
Alex Leung (Jira)
[jira] [Resolved] (KAFKA-16103) Review client logic for triggering offset commit callbacks
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-16599) Always await async commit callbacks in commitSync and close
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-16598) Mirgrate `ResetConsumerGroupOffsetTest` to new test infra
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16549) suppress the warnings from RemoteLogManager
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16596) Flaky test – org.apache.kafka.clients.ClientUtilsTest.testParseAndValidateAddressesWithReverseLookup()
Viktor Somogyi-Vass (Jira)
[jira] [Created] (KAFKA-16597) Flaky test - org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQuerySpecificStalePartitionStoresMultiStreamThreads()
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16596) Flaky test – org.apache.kafka.clients.ClientUtilsTest.testParseAndValidateAddressesWithReverseLookup()
Igor Soarez (Jira)
[jira] [Resolved] (KAFKA-15736) KRaft support in PlaintextConsumerTest
Walter Hernandez (Jira)
[jira] [Created] (KAFKA-16595) Introduce template in ClusterTests
Kuan Po Tseng (Jira)
[jira] [Created] (KAFKA-16594) Add a test to detect CDS errors
Vedarth Sharma (Jira)
[jira] [Resolved] (KAFKA-16591) RaftClusterInvocationContext ought to clear the admin queue when stopping
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16593) Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16552) Create an internal config to control InitialTaskDelayMs in LogManager to speed up tests
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16592) ConfigKey constructor update can break clients using it
Sagar Rao (Jira)
[jira] [Created] (KAFKA-16591) RaftClusterInvocationContext ought to clear the admin queue when stopping
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16590) Current offset is higher than last offset
MAHDI JAFARPUR (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2829
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2830
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2831
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2832
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2833
Apache Jenkins Server
[jira] [Resolved] (KAFKA-15585) DescribeTopic API
Calvin Liu (Jira)
[jira] [Created] (KAFKA-16589) Consider removing `ClusterInstance#createAdminClient` since callers are not sure whether they need to call close
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16486) Integrate metric measurability changes in metrics collector
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-16588) broker shutdown hangs when `log.segment.delete.delay.ms` is zero
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16579) Revert changes to consumer_rolling_upgrade_test.py for the new async Consumer
Philip Nee (Jira)
[VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Nikhil Ramakrishnan
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Justine Olshan
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Christo Lolov
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Andrew Schofield
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Luke Chen
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Nikhil Ramakrishnan
Re: [VOTE] KIP-1037: Allow WriteTxnMarkers API with Alter Cluster Permission
Nikhil Ramakrishnan
[DISCUSS] KIP-1039: Disable automatic topic creation for MirrorMaker2 consumers
aaron ai
Re: [DISCUSS] KIP-1039: Disable automatic topic creation for MirrorMaker2 consumers
Omnia Ibrahim
Earlier messages
Later messages