jira  

Messages by Thread

• • Re: [PR] MINOR: Kafka Streams should log broker provided KIP-1071 config values [kafka] via GitHub
• Re: [PR] 修复docker jvm构建错误(Fix Docker JVM build errors) [kafka] via GitHub
  • Re: [PR] 修复docker jvm构建错误(Fix Docker JVM build errors) [kafka] via GitHub
• Re: [PR] Enhanced mirror maker2 base 4.0.0 for fail-fast and reset handling [kafka] via GitHub
• Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
• Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
• [jira] [Updated] (KAFKA-20741) Add ReadOnlyRecord Interface Jess Jin (Jira)
• [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
  • Re: [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
  • Re: [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
  • Re: [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
  • Re: [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
  • Re: [PR] KAFKA-20741: Add ReadOnlyRecordIterator IQv2 result type (KIP-1356) [kafka] via GitHub
• [PR] MINOR: handle invalid StreamsHeartbeatRequest [kafka] via GitHub
  • Re: [PR] MINOR: handle invalid StreamsHeartbeatRequest [kafka] via GitHub
• Re: [PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka] via GitHub
• [jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment() Colt McNealy (Jira)
• [PR] KAFKA-20760: Fix for Position integration test and persiting Position object [kafka] via GitHub
  • Re: [PR] KAFKA-20760: Fix for PositionRestartIntegrationTest and persisting Position object [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20742) Start offset for newly initialized share partitions should be 0 Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-20760) IQv2 range queries fail and committed Position is lost on restart for transactional state store Bill Bejeck (Jira)
• [PR] KAFKA-20756: Parameterize for transactional state stores [kafka] via GitHub
• [jira] [Commented] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20759) testUnsubscribeDoesNotCommitOffsetsEvenWithAutoCommitEnabled hangs in closing Chia-Ping Tsai (Jira)
• [PR] KFK-19871: Add Runtime to TTD Multipartition [kafka] via GitHub
  • Re: [PR] KFK-19871: Add Runtime to TTD Multipartition [kafka] via GitHub
• [jira] [Updated] (KAFKA-20757) Run store-level unit suites through the transactional path Bill Bejeck (Jira)
• [jira] [Updated] (KAFKA-20758) Add lifecycle and recovery coverage Bill Bejeck (Jira)
• Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin[1/2] [kafka] via GitHub
  • [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
  • Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin [kafka] via GitHub
• [jira] [Created] (KAFKA-20758) Add lifecycle and recovery coverage Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20756) Parameterize integration tests over transactional state stores Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20757) Run store-level unit suites through the transactional path Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20755) Extend transactional state store test coverage Bill Bejeck (Jira)
• [PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka] via GitHub
  • Re: [PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka] via GitHub
  • Re: [PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka] via GitHub
  • Re: [PR] KAFKA-20746: NPE in MetadataCache#toCluster [kafka] via GitHub
• [PR] MINOR: Prevent overflow in CreateTopics partition validation [kafka] via GitHub
  • Re: [PR] MINOR: Prevent overflow in CreateTopics partition validation [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: Update the AK doc to include changes in KIP-1291 [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS Bill Bejeck (Jira)
• [jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS Bill Bejeck (Jira)
  • [jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS Bill Bejeck (Jira)
  • [jira] [Updated] (KAFKA-20753) Transactional RocksDB store fails to reopen with transactional status marker in EOS Bill Bejeck (Jira)
• [PR] KAFKA-17840: Move QuotaFactory to server module [kafka] via GitHub
• [jira] [Updated] (KAFKA-20754) Disallow static member instance id changes Sean Quah (Jira)
• [jira] [Created] (KAFKA-20754) Disallow static member instance id changes Sean Quah (Jira)
• [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka] via GitHub
  • Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka] via GitHub
  • Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka] via GitHub
  • Re: [PR] KAFKA-20736: Improve removal of unassigned partitions from share sessions [kafka] via GitHub
• [PR] KAFKA-10397: do not expose statistics-based RocksDB metrics when the user provides a Statistics object [kafka] via GitHub
  • Re: [PR] KAFKA-10397: do not expose statistics-based RocksDB metrics when the user provides a Statistics object [kafka] via GitHub
• [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka] via GitHub
  • Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka] via GitHub
  • Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka] via GitHub
  • Re: [PR] KAFKA-20750: Add divide-by-zero error check in KafkaConsumerMetrics/KafkaShareConsumerMetrics. [kafka] via GitHub
• [PR] KAFKA-10025: guard RocksDBMetricsRecorder value provider reads against store close [kafka] via GitHub
  • Re: [PR] KAFKA-10025: guard RocksDBMetricsRecorder value provider reads against store close [kafka] via GitHub
  • Re: [PR] KAFKA-10025: guard RocksDBMetricsRecorder value provider reads against store close [kafka] via GitHub
• [PR] KAFKA-20753: Fix transactional status marker writes [kafka] via GitHub
  • Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka] via GitHub
  • Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka] via GitHub
  • Re: [PR] KAFKA-20753: Fix transactional status marker writes [kafka] via GitHub
• [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka] via GitHub
  • Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka] via GitHub
  • Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka] via GitHub
  • Re: [PR] MINOR: Task-offset timer should not be reset if nothing was sent [kafka] via GitHub
• [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
  • Re: [PR] KAFKA-20742: Start offset for newly initialized share partitions of known topics should be 0 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation majialong (Jira)
• Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka] via GitHub
• Re: [PR] Support keystore with multiple alias entries [kafka] via GitHub
• [jira] [Created] (KAFKA-20753) Transactional RocksDB store fails to reopen (TaskCorrupted loop) when a task's active and standby are transiently co-located on one instance under EOS Bill Bejeck (Jira)
• [jira] [Comment Edited] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics Dan O'Reilly (Jira)
  • [jira] [Comment Edited] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics Dan O'Reilly (Jira)
• [jira] [Resolved] (KAFKA-20499) InMemoryStores readOnly implementations Bill Bejeck (Jira)
• [jira] [Commented] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics Dan O'Reilly (Jira)
• Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka] via GitHub
• [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] via GitHub
  • Re: [PR] KAFKA-20292 [5/N]: Fix UpdatedMembersAndTargetAssignmentView to handle instance id changes [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores Bill Bejeck (Jira)
• [jira] [Updated] (KAFKA-20720) Review level for client-side log on share session errors Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20720) Review level for client-side log on share session errors Lianet Magrans (Jira)
• [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] via GitHub
  • Re: [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] via GitHub
  • Re: [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] via GitHub
  • Re: [PR] KAFKA-20751: Preserve available versions for cached connector plugin validation failures [kafka] via GitHub
• [jira] [Updated] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation majialong (Jira)
• [jira] [Assigned] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores Bill Bejeck (Jira)
• Re: [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka] via GitHub
  • Re: [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka] via GitHub
• [jira] [Updated] (KAFKA-20747) Static member rejoining with same member id and different instance id not tracked correctly Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20747) Static member rejoining with same member id and different instance id not tracked correctly Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-20750) Divide-by-zero error in PollIdleRatio metric during sub-millisecond poll intervals. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-20750) Divide-by-zero error in PollIdleRatio metric during sub-millisecond poll intervals. Shivsundar R (Jira)
• [PR] KAFKA-20655: Mark KIP-1331 RPCs stable before release [kafka] via GitHub
  • Re: [PR] KAFKA-20655: Mark KIP-1331 RPCs stable before release [kafka] via GitHub
• Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] via GitHub
  • Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] via GitHub
  • Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] via GitHub
  • Re: [PR] KAFKA-18948 Move DynamicLogConfig to server module [kafka] via GitHub
• [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Stop offset writes leaking into data iteration [kafka] via GitHub
• [PR] KAFKA-20749: Fix for stream/stream joins and position bug [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Fix for stream/stream joins and position bug [kafka] via GitHub
  • Re: [PR] KAFKA-20749: Fix for stream/stream joins and position bug [kafka] via GitHub
• [jira] [Updated] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores Bill Bejeck (Jira)
  • [jira] [Updated] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20749) KStream-KStream outer/left join crashes under EOS with transactional state stores Bill Bejeck (Jira)
• [jira] [Commented] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races Lucas Brutschy (Jira)
• [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] via GitHub
  • Re: [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] via GitHub
  • Re: [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] via GitHub
  • Re: [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] via GitHub
  • Re: [PR] KAFKA-20747: Remove stale staticMembers entry when a member changes its instance id [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-20748) StoredDescriptionTopologyEpoch can diverge from the topology-description plugin across failures and races Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-20747) Static member rejoining with same member id and different instance id not tracked correctly Sean Quah (Jira)
• [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] via GitHub
  • Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] via GitHub
  • Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] via GitHub
  • Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] via GitHub
  • Re: [PR] KAFKA-20678: Add timeout in replica manager log reader remote read. [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20500) Transactional support for VersionedStores Nicholas Telford (Jira)
• [jira] [Comment Edited] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Michael Mitchell (Jira)
• [jira] [Resolved] (KAFKA-20678) Analyze and impl fetch from remote storage for DLQ Apoorv Mittal (Jira)
• [jira] [Assigned] (KAFKA-20697) Add cross-version system tests Gavin Wang (Jira)
• [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] via GitHub
  • Re: [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] via GitHub
  • Re: [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] via GitHub
  • Re: [PR] MINOR: Relax conditions to reduce rebalances with the classic consumer [kafka] via GitHub
• [PR] KAFKA-20739: Transaction coordinator accepts InitProducerId v6 keepPreparedTxn recovery [kafka] via GitHub
  • Re: [PR] KAFKA-20739: Transaction coordinator accepts InitProducerId v6 keepPreparedTxn recovery [kafka] via GitHub
• [PR] KAFKA-20738: Producer 2PC InitProducerId request must negotiate v6 [kafka] via GitHub
  • Re: [PR] KAFKA-20738: Producer 2PC InitProducerId request must negotiate v6 [kafka] via GitHub
  • Re: [PR] KAFKA-20738: Producer 2PC InitProducerId request must negotiate v6 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20733) KafkaConsumerTest.fetchResponseWithUnexpectedPartitionIsIgnored passes for wrong reason with CONSUMER protocol Lianet Magrans (Jira)
• [PR] KAFKA-20686: Reduce share heartbeat timeout in DLQ integ tests. [3/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20686: Reduce share heartbeat timeout in DLQ integ tests. [3/N] [kafka] via GitHub
• [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] via GitHub
  • Re: [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] via GitHub
  • Re: [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] via GitHub
  • Re: [PR] KAFKA-20553: Use ClusterInstance for streams group command tests [kafka] via GitHub
• [PR] MINOR: Clarify SerializationException Javadoc [kafka] via GitHub
  • Re: [PR] MINOR: Clarify SerializationException Javadoc [kafka] via GitHub
• [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
  • Re: [PR] MINOR: Remove clients test-fixtures shadow JAR rewire hack [kafka] via GitHub
• [PR] MINOR: Add static member replacement test with new subscription and not assignment [kafka] via GitHub
  • Re: [PR] MINOR: Add static member replacement test with new subscription and not assignment [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20730) Remove spotless from streams-scala Chia-Ping Tsai (Jira)
• [PR] MINOR: Document top-level-only field casting limitation in Cast SMT [kafka] via GitHub
  • Re: [PR] MINOR: Document top-level-only field casting limitation in Cast SMT [kafka] via GitHub
  • Re: [PR] MINOR: Document top-level-only field casting limitation in Cast SMT [kafka] via GitHub
• Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] via GitHub
  • Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] via GitHub
  • Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] via GitHub
  • Re: [PR] MINOR: Move client test utilities to test fixtures and resolve shadow jar conflicts [kafka] via GitHub
• [jira] [Resolved] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module Mickael Maison (Jira)
• [jira] [Assigned] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module Mickael Maison (Jira)
• Re: [PR] KAFKA-6786: Remove additional configs in StreamsBrokerDownResilienceTest [kafka] via GitHub

• Earlier messages
• Later messages