dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Created] (KAFKA-19243) Fix flaky testConcurrentRemoveReadForCache1
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19242) Fix commit bugs caused by race condition during rebalancing.
sanghyeok An (Jira)
[jira] [Created] (KAFKA-19241) reuse the same socket on subsequent share requests in ShareFetchAcknowledgeRequestTest
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-19240) Move MetadataVersionIntegrationTest to clients-integration-tests module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19239) Rewrite IntegrationTestUtils by java
Chia-Ping Tsai (Jira)
[VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder
Johnny Wang
Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder
Chia-Ping Tsai
Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder
PoAn Yang
Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder
黃竣陽
[VOTE] KIP-1130: Add metrics indicating the connection count exceeds
TengYao Chi
Re: [DISCUSS] KIP-1100: Consider renaming org.apache.kafka.server:type=AssignmentsManager
Chia-Ping Tsai
Re: [DISCUSS] KIP-1100: Consider renaming org.apache.kafka.server:type=AssignmentsManager
黃竣陽
[jira] [Created] (KAFKA-19238) We're facing issue in Kafka while reading data from Azure event hubs through Azure Databricks
karthickthavasiraj09 (Jira)
[jira] [Resolved] (KAFKA-19232) Handle share session limit reached error in clients
Shivsundar R (Jira)
[jira] [Resolved] (KAFKA-19060) Documented null edge cases in the Clients API JavaDoc
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19237) add dynamic config remote.log.manager.follower.thread.pool.size
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19236) Auto.offset.reset "by-duration" should reset a single time
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-18267) Add test for CloseOption
Chia-Ping Tsai (Jira)
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Chia-Ping Tsai
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Kamal Chandraprakash
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Chia-Ping Tsai
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Kamal Chandraprakash
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Chia-Ping Tsai
Re: [DISCUSS] KIP-1105: Make remote log manager thread-pool configs dynamic
Chia-Ping Tsai
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #286
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #287
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #288
Apache Jenkins Server
[jira] [Created] (KAFKA-19235) STALE_MEMBER_EPOCH is mostly non-recoverable and forces lost commits when leaving a group (KIP-848)
Travis Bischel (Jira)
[jira] [Created] (KAFKA-19234) broker should return UNAUTHORIZATION error for non-existing topic in produce request
Jun Rao (Jira)
[VOTE] KIP-1139: Add support for OAuth jwt-bearer grant type
Kirk True
[jira] [Created] (KAFKA-19233) Members cannot rejoin with epoch=0 for KIP-848
Travis Bischel (Jira)
[VOTE] KIP-1166: Improve high-watermark replication
José Armando García Sancio
[jira] [Created] (KAFKA-19232) Handle share session limit reached error in clients
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19172) Handle the evictions metric in ShareSessionCache
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-19231) Handle fetch request when share session cache is full
Chirag Wadhwa (Jira)
[jira] [Resolved] (KAFKA-17942) Fix testAcknowledgementCommitCallbackInvalidRecordStateException
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-19230) Fail build for FunctionalInterfaceMethodChanged warning
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19229) fix flaky testShareGroupDescribeWithGroupDescribeAndTopicDescribeAcl and testShareGroupDescribeWithoutGroupDescribeAcl
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19228) Formatting with `--no-initial-controllers` flag should not write kraft version control record
Kevin Wu (Jira)
[jira] [Resolved] (KAFKA-19146) Merge org.apache.kafka.server.common.OffsetAndEpoch and org.apache.kafka.raft.OffsetAndEpoch
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19227) Fix performance for share fetch with piggyback acknowledgements
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19073) Add Transactional ID pattern filter to ListTransactions API
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19210) investigate flakiness in GroupMetadataManagerTest.testShareGroupHeartbeatInitializeOnPartitionUpdate
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-19226) Add test_console_share_consumer system test
Chirag Wadhwa (Jira)
[jira] [Resolved] (KAFKA-19015) Remove share session from cache on connection drop
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19169) Enhance AuthorizerIntegrationTest for share group APIs
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-18760) Deprecate Optional<String> and return String from public EndPoint#Listener
PoAn Yang (Jira)
[jira] [Created] (KAFKA-19225) Tiered Storage Support for Active Log Segment
Henry Cai (Jira)
[DISCUSS] KIP-1176: Tiered Storage for Active Log Segment
Henry Haiying Cai
Re: [DISCUSS] KIP-1176: Tiered Storage for Active Log Segment
Luke Chen
Re: [DISCUSS] KIP-1176: Tiered Storage for Active Log Segment
Stanislav Kozlovski
Re: [DISCUSS] KIP-1176: Tiered Storage for Active Log Segment
Henry Haiying Cai
Re: [DISCUSS] KIP-1176: Tiered Storage for Active Log Segment
Henry Haiying Cai
[jira] [Created] (KAFKA-19224) Faster HWM replication for ISR topic partitions
Jira
[jira] [Created] (KAFKA-19223) Explicit HWM replication
Jira
[jira] [Created] (KAFKA-19222) Invalid FENCED_MEMBER_EPOCH error to ConsumerGroupHeartbeat
Travis Bischel (Jira)
[jira] [Created] (KAFKA-19221) IOException on log segment close shouldn't be ignored
Gaurav Narula (Jira)
[jira] [Resolved] (KAFKA-16718) Add AdminClient.deleteShareGroupOffsets
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19220) add tests to ensure the internal configs don't return by public APIs by default
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19219) improve KRaft migration log
Luke Chen (Jira)
[jira] [Created] (KAFKA-19218) Add missing leader epoch to read share group state summary response
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19216) Eliminate flakiness in kafka.server.share.SharePartitionTest
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19215) Handle share partition fetch lock cleanly in DelayedShareFetch to avoid a member incorrectly releasing a share partition's fetch lock
Abhinav Dixit (Jira)
[jira] [Resolved] (KAFKA-18288) Add support kafka-streams-groups.sh --describe
Alieh Saeedi (Jira)
[jira] [Resolved] (KAFKA-19173) Add `Feature` for streams groups
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
TengYao Chi (Jira)
[jira] [Resolved] (KAFKA-19135) Add IQ Support - move from feature branch
Bill Bejeck (Jira)
[jira] [Created] (KAFKA-19214) Clean up use of Optionals in RequestManagers.entries()
Kirk True (Jira)
[PR] KAFKA-19209: Clarify index.interval.bytes impact on offset and time index [kafka-site]
via GitHub
Re: [PR] KAFKA-19209: Clarify index.interval.bytes impact on offset and time index [kafka-site]
via GitHub
Re: [PR] KAFKA-19209: Clarify index.interval.bytes impact on offset and time index [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19213) Kafka java client ignores default properties
Pas Filip (Jira)
[jira] [Created] (KAFKA-19212) Fix ElectionWasClean method bug when partition reassignment completes
Calvin Liu (Jira)
[DISCUSS] KIP-1174: Expose addReadOnlyStateStore in DSL (StreamsBuilder)
Siddhartha Devineni
RE: [DISCUSS] KIP-1174: Expose addReadOnlyStateStore in DSL (StreamsBuilder)
Siddhartha Devineni
[DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters
pritam kumar
Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters
Greg Harris
Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters
pritam kumar
Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters
Chris Egerton
Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters
pritam kumar
[jira] [Created] (KAFKA-19211) Connect Storage Topics Sharing Across Clusters
Pritam Kumar (Jira)
[jira] [Created] (KAFKA-19210) investigate flakiness in GroupMetadataManagerTest.testShareGroupHeartbeatInitializeOnPartitionUpdate
Chirag Wadhwa (Jira)
[VOTE] KIP-1146: Anchored punctuation
Herman K. Jakobsen
Re: [VOTE] KIP-1146: Anchored punctuation
Sophie Blee-Goldman
Re: [VOTE] KIP-1146: Anchored punctuation
Matthias J. Sax
[jira] [Created] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
Luke Chen (Jira)
[jira] [Created] (KAFKA-19208) KStream-GlobalKTable join should not drop left-null-key record
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-19183) Replace Pool with ConcurrentHashMap
Chia-Ping Tsai (Jira)
a question of ISR and ack all
XiJun Ye
Re: a question of ISR and ack all
Haruki Okada
Re: a question of ISR and ack all
XiJun Ye
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #280
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #281
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #282
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #283
Apache Jenkins Server
[jira] [Resolved] (KAFKA-19178) Replace Vector by ArrayList for PluginClassLoader#getResources
Chia-Ping Tsai (Jira)
Request Confluence permission to submit KIP
鍾明諺
Re: Request Confluence permission to submit KIP
Matthias J. Sax
[jira] [Created] (KAFKA-19207) Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module
Chia-Ping Tsai (Jira)
[VOTE] KIP-1140: Avoid to return null value in Map from public api of consumer
黃竣陽
Re: [VOTE] KIP-1140: Avoid to return null value in Map from public api of consumer
Chia-Ping Tsai
Re: [VOTE] KIP-1140: Avoid to return null value in Map from public api of consumer
PoAn Yang
Re: [VOTE] KIP-1140: Avoid to return null value in Map from public api of consumer
Kirk True
[jira] [Created] (KAFKA-19206) AsyncKafkaConsumer hangs when NetworkClient fails authentication
Kirk True (Jira)
[jira] [Created] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19203) Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka-site]
via GitHub
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka-site]
via GitHub
[jira] [Created] (KAFKA-19202) Enable KIP-1071 in streams system tests where it makes sense
Lucas Brutschy (Jira)
[jira] [Resolved] (KAFKA-19131) Exception thrown while updating the RemoteLogReader threads
Kamal Chandraprakash (Jira)
[jira] [Resolved] (KAFKA-18889) Make records in ShareFetchResponse non-nullable
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19201) Handle deletion of a topic which has initialised share-group state
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19200) Indexes should be sanity checked on startup
Gaurav Narula (Jira)
Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #278
Apache Jenkins Server
[jira] [Resolved] (KAFKA-19081) Share session capacity and eviction
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19192) Old bootstrap.metadata files cause problems with post-KAFKA-18601 servers
Jira
[jira] [Created] (KAFKA-19199) Add broker side handling for 2PC with keepPrepared logic
Ritika Reddy (Jira)
Potential setup directions for windows
Eric K Richardson
[jira] [Created] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19196) Check whether FakeLocalMetadataStore#addACLs needs to be thread-safe.
Nick Guo (Jira)
Re: [DISCUSS] KIP-1043: Administration of groups
Chia-Ping Tsai
Re: [DISCUSS] KIP-1043: Administration of groups
Andrew Schofield
[VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Calvin Liu
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
David Jacot
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Chia-Ping Tsai
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Jun Rao
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Kirk True
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Justine Olshan
Re: [VOTE] KIP-1152: Add transactional ID pattern filter to ListTransactions API
Calvin Liu
[jira] [Resolved] (KAFKA-18671) Failed handling of fetch response should log an error message
Jira
[jira] [Resolved] (KAFKA-19191) Don't load bootstrap.checkpoint files if the cluster is already bootstrapped
Jira
[jira] [Resolved] (KAFKA-18992) kafka-features.sh wronly output `upgraded kraft.version to 1`
Jira
[jira] [Resolved] (KAFKA-16538) Support UpdateFeatures for kraft.version so we can go from static quorums to dynamic
Jira
[jira] [Created] (KAFKA-19197) Automatic generate metric list in document
PoAn Yang (Jira)
[jira] [Resolved] (KAFKA-19110) Add missing unit test for Streams-consumer integration
PoAn Yang (Jira)
[jira] [Created] (KAFKA-19195) Group describe operations are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[jira] [Resolved] (KAFKA-18170) Periodic snapshots for cold share partitions
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-19194) IOException thrown while starting Kafka broker if a file is present inside kafka data directory.
Srinath PS (Jira)
[jira] [Created] (KAFKA-19193) Rack-aware partitioning for Kafka Producer
Ivan Yurchenko (Jira)
[jira] [Created] (KAFKA-19192) Old bootstrap.metadata files cause problems with post-KAFKA-18601 servers
Colin McCabe (Jira)
[jira] [Created] (KAFKA-19191) Don't load bootstrap.checkpoint files if the cluster is already bootstrapped
Jira
[jira] [Resolved] (KAFKA-19118) Enable KIP-1071 in existing streams integration tests
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19190) StreamsUncaughtExceptionHandlerIntegrationTest fails
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19189) Handle deletion of __share_group_state topic in share coordinator
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-18629) DeleteShareGroups impl
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19156) Remove group.share.max.groups config
Andrew Schofield (Jira)
[DISCUSS] KIP-1164: Topic Based Batch Coordinator
Ivan Yurchenko
Re: [SPAM][DISCUSS] KIP-1164: Topic Based Batch Coordinator
yuxia
Re: [SPAM][DISCUSS] KIP-1164: Topic Based Batch Coordinator
Giuseppe Lillo
Re: [SPAM][DISCUSS] KIP-1164: Topic Based Batch Coordinator
yuxia
[DISCUSS] KIP-1163: Diskless Core
Ivan Yurchenko
[VOTE] 3.9.1 RC1
TengYao Chi
Re: [VOTE] 3.9.1 RC1
PoAn Yang
Re: [VOTE] 3.9.1 RC1
Kuan Po Tseng
Re: [VOTE] 3.9.1 RC1
Luke Chen
Re: [VOTE] 3.9.1 RC1
黃竣陽
Re: [VOTE] 3.9.1 RC1
Edoardo Comar
Re: [VOTE] 3.9.1 RC1
Edoardo Comar
Re: [VOTE] 3.9.1 RC1
TengYao Chi
Re: [VOTE] 3.9.1 RC1
Luke Chen
Re: [VOTE] 3.9.1 RC1
Justine Olshan
Re: [VOTE] 3.9.1 RC1
Justine Olshan
[jira] [Created] (KAFKA-19188) kafka-topics.sh --describe output for message.format.version is inconsistent immediately after cluster restart when not set at topic level
Jira
[jira] [Created] (KAFKA-19187) MINOR: Disallow raw types and fail build for test files
Abhinav Dixit (Jira)
[jira] [Created] (KAFKA-19186) Mark OffsetCommit and OffsetFetch APIs as stable
David Jacot (Jira)
[DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
David Arthur
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Colin McCabe
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Alyssa Huang
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Colin McCabe
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Alyssa Huang
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Ismael Juma
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Ismael Juma
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
David Arthur
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
Jun Rao
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Re: [DISCUSS] KIP-1166: Improve high-watermark replication
José Armando García Sancio
Earlier messages