kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
issue see https://issues.apache.org/jira/browse/KAFKA-17862 🔍 Problem Summary When an expired batch is still part of an in-flight request, we prematurely release the ByteBuffer back to the BufferPool. This leads to two...
4.0.2 has not been released yet, so marking it as a SNAPSHOT version Reviewers: Bill Bejeck
The reassignment completion logic currently requires that all target replicas be present in the in-sync replica set (ISR). If an unhealthy broker exists in both the current and target replica...
FeaturesPublisher's default finalizedFeatures assumes a metadata version of 7 when there is no finalized level for metadata.version. Instead of defaulting to 7, it should not report a value or report...
This pull request suggests adding a new stage for the state store lifecycle. Since we don't open and/or initialize temporary tasks, we can fix the issue described in this issue:...
Jira ticket: KAFKA-19809 Related link: https://checkstyle.org/releasenotes.html#Release_12.2.0 :warning: quick and dirty (aka skeleton) solution Reviews are welcome! Relates to: https://github.com/checkstyle/checkstyle/issues/16003
The following configs are weird because those values are definitely not READONLY - leader.replication.throttled.rate - follower.replication.throttled.rate - replica.alter.log.dirs.io.max.bytes.per.second Add them into the `DynamicBrokerConfig` to ensure when we query it's not...
This commit adds the new thread-level rebalance listener callback metrics from KIP-1216 to the Streams Monitoring section in ops.html: - tasks-revoked-latency-avg and tasks-revoked-latency-max - tasks-assigned-latency-avg and tasks-assigned-latency-max - tasks-lost-latency-avg and...
Added documentation for KIP-1071 broker metrics: - Extended group-count metric to include protocol=streams - Added streams-group-count metric with states: empty, not_ready, assigning, reconciling, stable, dead - Added streams-group-rebalance-rate and streams-group-rebalance-count...
adding handling of OOM and avoiding wrapped as timeout
