jira  

Messages by Thread

• [jira] [Created] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Lianet Magrans (Jira)
  • [jira] [Updated] (KAFKA-19351) AsyncConsumer#commitAsync should copy the input offsets Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18105) Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders Chang Chi Hsu (Jira)
• [jira] [Resolved] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord causes stateEpoch update misses. Andrew Schofield (Jira)
• [jira] [Assigned] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface Lorcan (Jira)
• [jira] [Resolved] (KAFKA-19056) Move EndToEndClusterIdTest to server module Chia-Ping Tsai (Jira)
• [PR] MINOR: Removed stale comment [kafka] via GitHub
  • Re: [PR] MINOR: Removed stale comment [kafka] via GitHub
• [jira] [Reopened] (KAFKA-16092) Queues for Kafka Apoorv Mittal (Jira)
• [jira] [Updated] (KAFKA-16092) Queues for Kafka Apoorv Mittal (Jira)
  • [jira] [Updated] (KAFKA-16092) Queues for Kafka Apoorv Mittal (Jira)
  • [jira] [Updated] (KAFKA-16092) Queues for Kafka Andrew Schofield (Jira)
• [jira] [Assigned] (KAFKA-16092) Queues for Kafka Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19285) Improve test coverage for SharePartitionManager Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19189) Handle deletion of __share_group_state topic in share coordinator Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-16092) Queues for Kafka Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19316) Add share_group_command_test.py system test Andrew Schofield (Jira)
• [PR] (WIP)KAFKA-19305 Ensure all image classes are immutable [kafka] via GitHub
  • Re: [PR] KAFKA-19305 Ensure all image classes are immutable [kafka] via GitHub
• [jira] [Commented] (KAFKA-16717) Add AdminClient.alterShareGroupOffsets Andrew Schofield (Jira)
• [jira] [Assigned] (KAFKA-19350) don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler Szu-Yung Wang (Jira)
• [jira] [Created] (KAFKA-19350) don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-19349) Move CreateTopicsRequestWithPolicyTest to clients-integration-tests Nick Guo (Jira)
• [jira] [Created] (KAFKA-19349) Move CreateTopicsRequestWithPolicyTest to clients-integration-tests Chia-Ping Tsai (Jira)
• [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
  • Re: [PR] KAFKA-19346: Move LogReadResult to server module [kafka] via GitHub
• [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] via GitHub
• [PR] KAFKA-18042: Reject the produce request with lower producer epoch early (KIP-890) [kafka] via GitHub
  • Re: [PR] KAFKA-18042: Reject the produce request with lower producer epoch early (KIP-890) [kafka] via GitHub
• Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
  • Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19344) Move assignable share partition method from describer to group spec. Andrew Schofield (Jira)
• [PR] KAFKA-19337: Write state writes snapshot for higher state epoch. [kafka] via GitHub
  • Re: [PR] KAFKA-19337: Write state writes snapshot for higher state epoch. [kafka] via GitHub
  • Re: [PR] KAFKA-19337: Write state writes snapshot for higher state epoch. [kafka] via GitHub
• [PR] MINOR: Follow up KAFKA-19080 MetadataLogConfig [kafka] via GitHub
  • Re: [PR] MINOR: Follow up KAFKA-19080 MetadataLogConfig [kafka] via GitHub
  • Re: [PR] MINOR: Follow up KAFKA-19080 MetadataLogConfig [kafka] via GitHub
  • Re: [PR] MINOR: Follow up KAFKA-19080 MetadataLogConfig [kafka] via GitHub
  • Re: [PR] MINOR: Follow up KAFKA-19080 MetadataLogConfig [kafka] via GitHub
• [PR] minor-reducing-system-test-cases: removed test cases with combined_kraft mode in share_consumer_test.py [kafka] via GitHub
  • Re: [PR] MINOR: removed test cases with combined_kraft mode in share_consumer_test.py [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19342) Add AuthorizerIntegrationTest for alter share group offsets Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19348) Move group metadata hash related functions to a class PoAn Yang (Jira)
• [jira] [Created] (KAFKA-19347) AclControlManager unsafe state update David Arthur (Jira)
• [PR] KAFKA-19347 Don't update timeline data structures in createAcls [kafka] via GitHub
  • Re: [PR] KAFKA-19347 Don't update timeline data structures in createAcls [kafka] via GitHub
  • Re: [PR] KAFKA-19347 Don't update timeline data structures in createAcls [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19310) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19336) Upgrade jackson libs since v2.16 is not maintained anymore Chia-Ping Tsai (Jira)
• [jira] [Commented] (KAFKA-19125) Implement Large message reference-based Serializer Andrew Olson (Jira)
• [PR] (WIP) MINOR: fix failed streams e2e tests [kafka] via GitHub
  • Re: [PR] (WIP) MINOR: fix failed streams e2e tests [kafka] via GitHub
  • Re: [PR] MINOR: fix failed StreamsBrokerBounceTest e2e tests [kafka] via GitHub
  • Re: [PR] MINOR: fix failed StreamsBrokerBounceTest e2e tests [kafka] via GitHub
  • Re: [PR] MINOR: fix failed StreamsBrokerBounceTest e2e tests [kafka] via GitHub
• [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
  • [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed David Jacot (Jira)
  • [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
  • [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed David Jacot (Jira)
  • [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
  • [jira] [Commented] (KAFKA-19341) Execution of HighWatermarkUpdate failed David Jacot (Jira)
• Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw key and value [kafka] via GitHub
• [jira] [Commented] (KAFKA-19221) IOException on log segment close shouldn't be ignored Omnia Ibrahim (Jira)
  • [jira] [Commented] (KAFKA-19221) IOException on log segment close shouldn't be ignored Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-19221) IOException on log segment close shouldn't be ignored Omnia Ibrahim (Jira)
  • [jira] [Updated] (KAFKA-19221) IOException on log segment close shouldn't be ignored Omnia Ibrahim (Jira)
  • [jira] [Updated] (KAFKA-19221) IOException on log segment close shouldn't be ignored Omnia Ibrahim (Jira)
• [jira] [Assigned] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Abhinav Dixit (Jira)
  • [jira] [Assigned] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Abhinav Dixit (Jira)
• Re: [PR] KAFKA-16505: Add source raw bytes in processorContex [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Add source raw bytes in processorContex [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
• [jira] [Created] (KAFKA-19346) Move LogReadResult to server module Lan Ding (Jira)
• [PR] KAFKA-19344: Replace desc.assignablePartitions with spec.isPartitionAssignable. [kafka] via GitHub
  • Re: [PR] KAFKA-19344: Replace desc.assignablePartitions with spec.isPartitionAssignable. [kafka] via GitHub
  • Re: [PR] KAFKA-19344: Replace desc.assignablePartitions with spec.isPartitionAssignable. [kafka] via GitHub
  • Re: [PR] KAFKA-19344: Replace desc.assignablePartitions with spec.isPartitionAssignable. [kafka] via GitHub
• [jira] [Commented] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Kuan Po Tseng (Jira)
  • [jira] [Commented] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Abhinav Dixit (Jira)
• [PR] MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits [kafka] via GitHub
• [PR] KAFKA-19321: Added share_consumer_performance.py and related system tests [kafka] via GitHub
  • Re: [PR] KAFKA-19321: Added share_consumer_performance.py and related system tests [kafka] via GitHub
  • Re: [PR] KAFKA-19321: Added share_consumer_performance.py and related system tests [kafka] via GitHub
  • Re: [PR] KAFKA-19321: Added share_consumer_performance.py and related system tests [kafka] via GitHub
  • Re: [PR] KAFKA-19321: Added share_consumer_performance.py and related system tests [kafka] via GitHub
• [jira] [Created] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Abhinav Dixit (Jira)
• [jira] [Created] (KAFKA-19344) Move assignable share partition method from describer to group spec. Sushant Mahajan (Jira)
• [PR] KAFKA-19336 Upgrade Jackson to 2.19.0 [kafka] via GitHub
  • Re: [PR] KAFKA-19336 Upgrade Jackson to 2.19.0 [kafka] via GitHub
  • Re: [PR] KAFKA-19336 Upgrade Jackson to 2.19.0 [kafka] via GitHub
• Re: [PR] MINOR: Specify ArrayDeque init size to NUM_BATCHES_TO_RETAIN in ProducerStateEntry [kafka] via GitHub
• Re: [PR] KAFKA-18337: KafkaProducer Memory Leak in JmxReporter Class [kafka] via GitHub
  • Re: [PR] KAFKA-18337: KafkaProducer Memory Leak in JmxReporter Class [kafka] via GitHub
• [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
  • Re: [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
  • Re: [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
  • Re: [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
  • [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
  • Re: [PR] [WIP] MINOR: bump dependency test [kafka] via GitHub
• [PR] KAFKA-19271: allow intercepting internal method call [kafka] via GitHub
  • Re: [PR] KAFKA-19271: allow intercepting internal method call [kafka] via GitHub
  • Re: [PR] KAFKA-19271: allow intercepting internal method call [kafka] via GitHub
  • Re: [PR] KAFKA-19271: allow intercepting internal method call [kafka] via GitHub
  • Re: [PR] KAFKA-19271: allow intercepting internal method call [kafka] via GitHub
• [jira] [Updated] (KAFKA-19335) Streams group heartbeat sometimes fails with INVALID_REQUEST Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19266) Eliminate flakiness in test SharePartitionTest.testAcquisitionLockTimeoutForBatchesPostStartOffsetMovement Abhinav Dixit (Jira)
• [jira] [Commented] (KAFKA-19266) Eliminate flakiness in test SharePartitionTest.testAcquisitionLockTimeoutForBatchesPostStartOffsetMovement Abhinav Dixit (Jira)
• [jira] [Created] (KAFKA-19343) Misconfigured broker listeners causes unrecoverable controller error Jira
• [jira] [Assigned] (KAFKA-14895) Move AddPartitionsToTxnManager files to java Justine Olshan (Jira)
• [PR] KAFKA-16894: share.version becomes stable feature for preview [kafka] via GitHub
  • Re: [PR] KAFKA-16894: share.version becomes stable feature for preview [kafka] via GitHub
  • Re: [PR] KAFKA-16894: share.version becomes stable feature for preview [kafka] via GitHub
  • Re: [PR] KAFKA-16894: share.version becomes stable feature for preview [kafka] via GitHub
• [PR] KAFKA-19342: Authorization tests for alter share-group offsets [kafka] via GitHub
  • Re: [PR] KAFKA-19342: Authorization tests for alter share-group offsets [kafka] via GitHub
  • Re: [PR] KAFKA-19342: Authorization tests for alter share-group offsets [kafka] via GitHub
  • Re: [PR] KAFKA-19342: Authorization tests for alter share-group offsets [kafka] via GitHub
• [PR] MINOR: Improve share coordinator record schemas [kafka] via GitHub
  • Re: [PR] MINOR: Improve share coordinator record schemas [kafka] via GitHub
• [PR] MINOR: Align tool output for deletion of groups [kafka] via GitHub
  • Re: [PR] MINOR: Align tool output for deletion of groups [kafka] via GitHub
• [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
  • Re: [PR] MINOR: fixing updateBrokerContactTime [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19154) Return INVALID_OFFSET if requested topic id does not match persisted one David Jacot (Jira)
• [jira] [Resolved] (KAFKA-18823) native docker don't honor the result of checking sign key Chia-Ping Tsai (Jira)
• [PR] KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module [kafka] via GitHub
  • Re: [PR] KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module [kafka] via GitHub
  • Re: [PR] KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module [kafka] via GitHub
  • Re: [PR] KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module [kafka] via GitHub
  • Re: [PR] KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module [kafka] via GitHub
• Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (offset-related APIs) [1/N] [kafka] via GitHub
• [jira] [Created] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
• [jira] [Created] (KAFKA-19338) Share coordinator read state and write state should return error, if the share partition is not initialized. Sushant Mahajan (Jira)
• [jira] [Updated] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
  • [jira] [Updated] (KAFKA-19341) Execution of HighWatermarkUpdate failed Patrik Kleindl (Jira)
• [jira] [Created] (KAFKA-19342) Add AuthorizerIntegrationTest for alter share group offsets Andrew Schofield (Jira)
• [jira] [Updated] (KAFKA-19340) Move DelayedRemoteFetch to the storage module Lan Ding (Jira)
  • [jira] [Updated] (KAFKA-19340) Move DelayedRemoteFetch to the storage module Lan Ding (Jira)
• [jira] [Created] (KAFKA-19340) Move DelayedRemoteFetch to the storage module Lan Ding (Jira)
• [jira] [Created] (KAFKA-19339) Move DelayedFetch to server module Kuan Po Tseng (Jira)
• [jira] [Updated] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord causes stateEpoch update misses. Sushant Mahajan (Jira)
• [PR] MINOR: Migrate usages of the deprecated Endpoint#listenerName to the Endpoint#listener [kafka] via GitHub
  • Re: [PR] MINOR: Migrate usage of deprecated Endpoint#listenerName() to Endpoint#listener() [kafka] via GitHub
• [jira] [Updated] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord prevents stateEpoch update misses. Sushant Mahajan (Jira)
  • [jira] [Updated] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord prevents stateEpoch update misses. Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord prevents stateEpoch update misses. Sushant Mahajan (Jira)
• [jira] [Assigned] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19330) MockSerializer should extend Serializer<String> Chia-Ping Tsai (Jira)
• [PR] MINOR: Remove flakiness caused when producing aborted transaction in ShareConsumerTest [kafka] via GitHub
  • Re: [PR] MINOR: Remove flakiness caused when producing aborted transaction in ShareConsumerTest [kafka] via GitHub
• [jira] [Resolved] (KAFKA-18687) New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement David Jacot (Jira)
• [jira] [Updated] (KAFKA-17301) lz4-java is not maintained anymore Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19336) Upgrade jackson libs since v2.16 is not maintained anymore Luke Chen (Jira)
• [PR] KAFKA-19310: (MINOR) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing [kafka] via GitHub
  • Re: [PR] KAFKA-19310: (MINOR) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing [kafka] via GitHub

• Earlier messages
• Later messages