dev  

Messages by Thread

• • Re: read cluster metadata topic Chia-Ping Tsai
  • Re: read cluster metadata topic Péter Sinóros-Szabó
  • Re: read cluster metadata topic José Armando García Sancio
  • Re: read cluster metadata topic Péter Sinóros-Szabó
  • Re: read cluster metadata topic José Armando García Sancio
  • Re: read cluster metadata topic Chia-Ping Tsai
• Message format compatibility during/after upgrade Atul Sharma
• [jira] [Created] (KAFKA-19171) Kafka Streams crashes with UnsupportedOperationException Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19170) Migrate MetricsDuringTopicCreationDeletionTest to clients-integration-tests module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19169) Enhance AuthorizerIntegrationTest for share group APIs Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-14523) Move RemoteLogManager to the storage module Mickael Maison (Jira)
• [jira] [Reopened] (KAFKA-19024) Enhance the client behaviour when it tries to exceed the `group.share.max.groups` Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19168) MirrorMaker kafka_metrics_count metric is always incorrect Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19151) Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19054) StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19167) Move RemoteLogManagerConfig out of KafkaConfig Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19024) Enhance the client behaviour when it tries to exceed the `group.share.max.groups` Lan Ding (Jira)
  • [jira] [Resolved] (KAFKA-19024) Enhance the client behaviour when it tries to exceed the `group.share.max.groups` Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19166) Release tags are orphaned David Arthur (Jira)
• [jira] [Resolved] (KAFKA-19002) Rewrite ListOffsetsIntegrationTest and move it to clients-integration-test Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19165) PartitionLeaderStrategy has very high error rate during topic initialization Steven Schlansker (Jira)
• [jira] [Created] (KAFKA-19164) New group coordinator won't delete groups with previously pending transactional offsets that were deleted Sean Quah (Jira)
• [jira] [Created] (KAFKA-19163) New group coordinator can incorrectly delete groups with pending transactional offsets Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-19158) Add a new error code for “share session limit reached” Andrew Schofield (Jira)
• [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
  • Re: [PR] Added missing `/migration` znode deletion on rollback KRaft migration [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19162) Topology description sent to broker contains non-determinstically ordered topic configs Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-19147) ConsumerGroupHeartbeat API leaks topic id and partition count of unauthorized topics Rajini Sivaram (Jira)
• [jira] [Created] (KAFKA-19161) Diskless Topics Ivan Yurchenko (Jira)
• [DISCUSS] KIP-1150 Diskless Topics Josep Prat
  • Re: [DISCUSS] KIP-1150 Diskless Topics Luke Chen
  • Re: [DISCUSS] KIP-1150 Diskless Topics Ivan Yurchenko
  • Re: [DISCUSS] KIP-1150 Diskless Topics Ziming Deng
  • Re: [DISCUSS] KIP-1150 Diskless Topics Ivan Yurchenko
  • Re: [DISCUSS] KIP-1150 Diskless Topics Stanislav Kozlovski
  • Re: [DISCUSS] KIP-1150 Diskless Topics Christo Lolov
  • Re: [SPAM]Re: [DISCUSS] KIP-1150 Diskless Topics yuxia
  • Re: [SPAM]Re: [DISCUSS] KIP-1150 Diskless Topics Ivan Yurchenko
  • Re: [DISCUSS] KIP-1150 Diskless Topics Ivan Yurchenko
  • Re: [DISCUSS] KIP-1150 Diskless Topics Xiaorui Wang
  • Re: [DISCUSS] KIP-1150 Diskless Topics Luke Chen
  • Re: [DISCUSS] KIP-1150 Diskless Topics Xiaorui
• [jira] [Created] (KAFKA-19160) Fetching stable offsets is very slow with a large number of partition and open transactions Sean Quah (Jira)
• [jira] [Created] (KAFKA-19159) Remove time based eviction of share sessions from the cache Chirag Wadhwa (Jira)
• [jira] [Resolved] (KAFKA-19115) Utilize initialized topics info to verify delete share group offsets Chirag Wadhwa (Jira)
• [jira] [Created] (KAFKA-19158) Add a new error code for “share session not created” Chirag Wadhwa (Jira)
• [jira] [Created] (KAFKA-19156) Remove group.share.max.groups config Chirag Wadhwa (Jira)
• [jira] [Created] (KAFKA-19157) Add group.share.max.share.session.cache.slots config Chirag Wadhwa (Jira)
• [jira] [Created] (KAFKA-19155) Update docs/security.html for streams-related RPCs Lucas Brutschy (Jira)
• Custom Kafka Connect REST Extension for Token Authentication Jamie
  • Re: Custom Kafka Connect REST Extension for Token Authentication Jamie
  • Re: Custom Kafka Connect REST Extension for Token Authentication Chris Egerton
  • Re: Custom Kafka Connect REST Extension for Token Authentication Yeikel Santana
• Kafka upgrade guide from 2.8.2 to 3.5.1 Kartik Dev
  • Re: Kafka upgrade guide from 2.8.2 to 3.5.1 Colin McCabe
• Request to contribute to Apache Kafka Giuseppe Lillo
  • Re: Request to contribute to Apache Kafka Matthias J. Sax
• [VOTE] 3.9.1 RC0 TengYao Chi
  • Re: [VOTE] 3.9.1 RC0 Matthias J. Sax
  • Re: [VOTE] 3.9.1 RC0 David Arthur
  • Re: [VOTE] 3.9.1 RC0 TengYao Chi
  • Re: [VOTE] 3.9.1 RC0 Luke Chen
• Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes Lucas Brutschy
  • Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes Andrew Schofield
  • Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes David Jacot
  • Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes TengYao Chi
  • Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes PoAn Yang
• [jira] [Created] (KAFKA-19154) Return INVALID_OFFSET if requested topic id does not match persisted one David Jacot (Jira)
• [jira] [Created] (KAFKA-19153) Add OAuth integration tests using Keycloak Kirk True (Jira)
• [jira] [Created] (KAFKA-19152) Add top-level documentation for OAuth flows Kirk True (Jira)
• [jira] [Created] (KAFKA-19151) Enhance the docs of flush.ms by reminding users the flush is triggered by log.flush.scheduler.interval.ms Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18888) Add support for Authorizer Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-18983) Ensure all README.md(s) are mentioned by the root README.md Chia-Ping Tsai (Jira)
• Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #190 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #191 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-19061) Add ACL changes to enable role based 2PC Ritika Reddy (Jira)
• [jira] [Created] (KAFKA-19140) ConnectAssignor#performAssignment second parameter can be replace from String to ConnectProtocolCompatibility Jira
• [jira] [Created] (KAFKA-19149) Use KIP-877 in MirrorMaker Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19145) Move LeaderEndPoint to server module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18902) Implement ShareConsumer option to throw on poll if there are unacked records Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19043) Move DelayedRemoteListOffsets to the storage module Ismael Juma (Jira)
• [jira] [Created] (KAFKA-19150) Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics Mickael Maison (Jira)
• [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty Jun Rao
  • Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty 黃竣陽
• [jira] [Resolved] (KAFKA-18900) Create a consumer config to select between implicit and explicit acknowledgement Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19137) Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false Julian Bergner (Jira)
• [jira] [Created] (KAFKA-19147) ConsumerGroupHeartbeat API leaks topic id and partition count of unauthorized topics Rajini Sivaram (Jira)
• [DISCUSS] KIP-1160: Enable returning supported features from a specific broker PoAn Yang
• [jira] [Created] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19144) Move DelayedProduce to server module Chia-Ping Tsai (Jira)
• Kafka tags on repo jgoodyear
  • Re: Kafka tags on repo David Arthur
  • Re: Kafka tags on repo David Arthur
  • Re: Kafka tags on repo Luke Chen
  • Re: Kafka tags on repo Jamie Mark Goodyear
• [jira] [Created] (KAFKA-19141) Persist topic id in OffsetCommitValue David Jacot (Jira)
• [jira] [Created] (KAFKA-19143) Setup periodic job to clean share group deleting metadata state in GC Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-18172) Move RemoteIndexCacheTest to storage module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19119) Move ApiVersionManager/SimpleApiVersionManager Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19121) Move AddPartitionsToTxnConfig, TransactionStateManagerConfig, and QuorumConfig out of KafkaConfig Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19137) Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19142) TestKitNodes doesn't bootstrap KIP-853 correctly Jira
• [jira] [Resolved] (KAFKA-19113) Migrate DelegationTokenManager to server module Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19102) Enhance the docs of group.coordinator.append.linger.ms TengYao Chi (Jira)
• [jira] [Resolved] (KAFKA-19027) Replace ConsumerGroupCommandTestUtils#generator by ClusterTestDefaults Chia-Ping Tsai (Jira)
• EmbeddedConnectCluster with multiple Connectors Claude Warren, Jr
  • Re: EmbeddedConnectCluster with multiple Connectors Greg Harris
• [jira] [Created] (KAFKA-19139) Plugin#wrapInstance should use LinkedHashMap instead of Map Jira
• [jira] [Created] (KAFKA-19138) Kafka service is continuously restarting in one of the nodes in 3 node cluster Sravani (Jira)
• [jira] [Created] (KAFKA-19136) Merge MetadataLogConfig into KRaftConfigs Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-15371) MetadataShell is stuck when bootstrapping Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19071) Incorrect documentation for remote.storage.enable Luke Chen (Jira)
• [jira] [Created] (KAFKA-19135) Add IQ Support - move from feature branch Bill Bejeck (Jira)
• [DISCUSS] KIP-1130: Add metrics indicating the connection count exceeds TengYao Chi
  • Re: [DISCUSS] KIP-1130: Add metrics indicating the connection count exceeds Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1130: Add metrics indicating the connection count exceeds TengYao Chi
• [jira] [Resolved] (KAFKA-19030) Remove metricNamePrefix from RequestChannel Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19134) Implementation of a Simple, Low-Latency Bounded Shared Buffer Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19133) Support fetching for multiple remote fetch topic partitions in a single share fetch request Abhinav Dixit (Jira)
• [jira] [Created] (KAFKA-19132) Move FetchSession and related classes to server module Dmitry Werner (Jira)
• Re: [jira] [Commented] (KAFKA-19092) Flaky test QuorumControllerTest#testBalancePartitionLeaders Divya Guduru
• [jira] [Created] (KAFKA-19131) Exception thrown while updating the RemoteLogReader threads Kamal Chandraprakash (Jira)
• [PR] MINOR: Add release signing key [kafka-site] via GitHub
  • Re: [PR] MINOR: Add release signing key [kafka-site] via GitHub
  • Re: [PR] MINOR: Add release signing key [kafka-site] via GitHub
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #265 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #266 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #267 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #268 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #269 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #270 Apache Jenkins Server
• [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor 黃竣陽
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor 黃竣陽
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Matthias J. Sax
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor 黃竣陽
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor TengYao Chi
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor Sophie Blee-Goldman
• [jira] [Created] (KAFKA-19130) Do not add fenced brokers to BrokerRegistrationTracker on startup Colin McCabe (Jira)
• [jira] [Created] (KAFKA-19128) Kafka Streams should not get offsets when close dirty Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-19129) Add a comment to BootstrapMetadata#copyWithFeatureRecord TengYao Chi (Jira)
• [PR] MINOR: Add Apoorv Mittal to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add Apoorv Mittal to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add Apoorv Mittal to committers [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19101) Remove ControllerMutationQuotaManager#throttleTimeMs unused parameter Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18782) Extend ApplicationRecoverableException related exceptions Justine Olshan (Jira)
• [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
  • Re: [PR] MINOR: Add TengYao to committers [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19101) Remove ControllerMutationQuotaManager#throttleTimeMs unused parameter Jira
• KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] PoAn Yang
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Justine Olshan
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Andrew Schofield
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Jun Rao
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] José Armando García Sancio
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Matthias J. Sax
  • Re: KIP-1155: Metadata Version Downgrades [DISCUSS] Colin McCabe
• [jira] [Created] (KAFKA-19119) Move ApiVersionManager/SimpleApiVersionManager Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-17996) kafka-metadata-quorum.sh add-controller cause the new added controller to crash with java.lang.IllegalArgumentException Omnia Ibrahim (Jira)
• Unexpected UNCLEAN leader election behaviour in KRaft vs. Zookeeper Julian Bergner
  • Re: Unexpected UNCLEAN leader election behaviour in KRaft vs. Zookeeper Colin McCabe
  • Re: Unexpected UNCLEAN leader election behaviour in KRaft vs. Zookeeper Julian Bergner
• [jira] [Created] (KAFKA-19123) the buffer of forwarded request should be released after receiving the reponse from controller Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19121) Move AddPartitionsToTxnConfig, TransactionStateManagerConfig, and QuorumConfig out of KafkaConfig Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19037) Integrate consumer-side code with Streams Bruno Cadonna (Jira)
• [ANNOUNCE] New committer: Apoorv Mittal Matthias J. Sax
  • Re: [ANNOUNCE] New committer: Apoorv Mittal Chia-Ping Tsai
  • Re: [ANNOUNCE] New committer: Apoorv Mittal Lucas Brutschy

• Earlier messages
• Later messages