Messages by Thread
-
-
[jira] [Assigned] (KAFKA-18834) Fix LoggingResourceTest#testSetLevelDefaultScope
HongYi Chen (Jira)
-
Re: [PR] KAFKA-18679: KafkaRaftMetrics metrics are exposing doubles instead of integers [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-18834) Fix LoggingResourceTest#testSetLevelDefaultScope
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-18834 Fix LoggingResourceTest#testSetLevelDefaultScope [kafka]
via GitHub
-
Re: [PR] [WIP] KAFKA-18562: standardize election/fetch timeout between Unattached and Followers [kafka]
via GitHub
-
Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka]
via GitHub
-
Re: [PR] MINOR: migrate SaslClientsWithInvalidCredentialsTest to use ClusterTestExtensions [kafka]
via GitHub
-
Re: [PR] KAFKA-10357 Add Internal Topic Exceptions [kafka]
via GitHub
-
Re: [PR] KAFKA-19415 Shuffle the order of readPartitionInfo when fetching data. [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-13386) Foreign Key Join filtering out valid records after a code change / schema evolved
Antoine Michaud (Jira)
-
[PR] MINOR: Improve ProcessorContext JavaDocs [kafka]
via GitHub
-
[PR] KAFKA-19436: Restrict cache update for ongoing batch/offset state [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19436) Acquisition lock timeout can't find some offsets to release
Apoorv Mittal (Jira)
-
[PR] KAFKA-19427: Allow the coordinator to grow its buffer dynamically [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-19282) Update quotaTypesEnabled on quota removal in ClientQuotaManager
Rajini Sivaram (Jira)
-
[jira] [Updated] (KAFKA-18922) RequestContext#principalSerde should not be optional as it is now always present
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18216) High water mark or last stable offset aren't always updated after a fetch request is completed
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18913) Consider removing state-updater feature flag
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Mickael Maison (Jira)
-
[PR] KAFKA-19379: Basic upgrade guide for KIP-1071 EA [kafka]
via GitHub
-
Re: [PR] KAFKA-19383: Handle the deleted topics when applying ClearElrRecord [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19265) Use snapshotting of remote log metedata topic that is used when a broker is restarted.
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-15419) Flaky DescribeClusterRequestTest
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18002) Upgrade connect_distributed_test.py's test_exactly_once_source to support different group.protocol values
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18190) TopologyTestDriver time is not synchronized with test topics
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18002) Upgrade connect_distributed_test.py's test_exactly_once_source to support different group.protocol values
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-19434) Move logic for for state store initiation to StreamThread handover
Bill Bejeck (Jira)
-
Re: [PR] KAFKA-19408 : Add check for compression type mismatch for push telemetry requests [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-18752) Fix the warning of no-operation caused by slf4j in building kafka
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID
Mickael Maison (Jira)
-
[PR] Add initPid Response handling when keepPrepared is set to true [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-18509) Cleanup StateChangeLogger
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19246) OffsetFetch API does not return group level errors correctly with version 1
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets
Mickael Maison (Jira)
-
Re: [PR] KAFKA-19414: Remove 2PC public APIs from 4.1 until release (KIP-939) [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19184) Document kraft version upgrade
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19186) Mark OffsetCommit and OffsetFetch APIs as stable
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-19414) Remove Public APIs from 4.1
Justine Olshan (Jira)
-
[jira] [Updated] (KAFKA-15757) Do not advertise v4 AddPartitionsToTxn to clients
Justine Olshan (Jira)
-
[jira] [Updated] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19050) kafka-streams-integration-tests artifact is empty
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19050) kafka-streams-integration-tests artifact is empty
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-15419) Flaky DescribeClusterRequestTest
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-17777) Flaky KafkaConsumerTest testReturnRecordsDuringRebalance
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-14402) Transactions Server Side Defense
Justine Olshan (Jira)
-
[jira] [Updated] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
RivenSun (Jira)
-
[jira] [Commented] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19078) Implement automatic controller addition to cluster metadata partition
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19078) Implement automatic controller addition to cluster metadata partition
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which causes the coordinator broker to allocate too much memory and cause OOM
RivenSun (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
PoAn Yang (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
David Jacot (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
RivenSun (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Ismael Juma (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
David Jacot (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Ismael Juma (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Federico Valeri (Jira)
-
[jira] [Commented] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Luke Chen (Jira)
-
[jira] [Updated] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflicts.
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-17651) Implement `describeUserScramCredentials`
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-17651) Implement `describeUserScramCredentials`
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-17178) Update KTable.transformValues to new Processor API
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-4566) Can't Symlink to Kafka bins
Mickael Maison (Jira)
-
[PR] MINOR: Use primitive data types in tools [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-18477) remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflicts.
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19407) OffsetsOutOfOrderException on followers due to the race condition in the leader
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-19255) KRaft request manager should support one in-flight request per request type
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-18656) Backport KAFKA-18597 to 4.0
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-18973) Review MetadataSchemaCheckerToolTest.testVerifyEvolutionGit requiring git project
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18965) Improve release validation for kafka-clients
Mickael Maison (Jira)
-
[PR] MINOR: Fix response for consumer group describe with empty group id (#20030) [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-18913) Consider removing state-updater feature flag
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18190) TopologyTestDriver time is not synchronized with test topics
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18824) Update docs of docker hub to add dynamic voters description
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-16580) Write simulation tests for kraft membership change
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-14830) Illegal state error in transactional producer
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-16580) Write simulation tests for kraft membership change
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18965) Improve release validation for kafka-clients
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19122) updateClusterMetadata receives multiples PartitionInfo
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19047) Broker registrations are slow if previously fenced or shutdown
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19122) updateClusterMetadata receives multiples PartitionInfo
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-14830) Illegal state error in transactional producer
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18735) the zk-related path `<default>` is still used by quota callback
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18735) the zk-related path `<default>` is still used by quota callback
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18216) High water mark or last stable offset aren't always updated after a fetch request is completed
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18217) Slow HWM/LSO update might have subtle effect on the consumer lag reporting
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18217) Slow HWM/LSO update might have subtle effect on the consumer lag reporting
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-17727) Log dirs marked as offline incorrectly due to race conditions on segment delete
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-17727) Log dirs marked as offline incorrectly due to race conditions on segment delete
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-14402) Transactions Server Side Defense
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-14402) Transactions Server Side Defense
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19255) KRaft request manager should support one in-flight request per request type
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18824) Update docs of docker hub to add dynamic voters description
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18857) Avoid authorization check in the group coordinator
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19048) Minimal Movement Replica Balancing algorithm for reassignment
Mickael Maison (Jira)
-
Re: [PR] KAFKA-19168: MirrorMaker kafka_metrics_count metric is always incorrect [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.
Luke Chen (Jira)
-
[jira] [Created] (KAFKA-19435) Optimize `kafka-consumer-groups.sh` to return the offset info of other partitions even when the leader of some partitions are missing
kangning.li (Jira)
-
[jira] [Updated] (KAFKA-18973) Review MetadataSchemaCheckerToolTest.testVerifyEvolutionGit requiring git project
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18857) Avoid authorization check in the group coordinator
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19265) Use snapshotting of remote log metedata topic that is used when a broker is restarted.
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18752) Fix the warning of no-operation caused by slf4j in building kafka
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-18390) Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-18390) Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19254) Add generic feature level metric
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-17178) Update KTable.transformValues to new Processor API
Mickael Maison (Jira)