[jira] [Created] (KAFKA-13829) The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data

RivenSun created KAFKA-13829: Summary: The function of max.in.flight.requests.per.connection parameter does not work, it conflicts with the underlying NIO sending data Key: KAFKA-13829 URL: https://issues.apache.org/j

[GitHub] [kafka-site] cadonna opened a new pull request, #405: Add Bruno's public key to KEYS

cadonna opened a new pull request, #405: URL: https://github.com/apache/kafka-site/pull/405 Adds Bruno Cadonna's public key to KEYS which is needed to release Apache Kafka 3.2.0. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

Re: [VOTE] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

Yet another quick FYI. While implementing KIP-820, we found that `api.MockProcessorContext` was missing these new methods as well. We added the new method to the new `api.MockProcessorContext` via https://issues.apache.org/jira/browse/KAFKA-13654. Please let us know if there are any concerns. I

[jira] [Resolved] (KAFKA-12613) Inconsistencies between Kafka Config and Log Config

[ https://issues.apache.org/jira/browse/KAFKA-12613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-12613. Fix Version/s: 3.3.0 Resolution: Fixed > Inconsistencies between Kafka Config and L

Re: [VOTE] KIP-797: Accept duplicate listener on port for IPv4/IPv6

Hi David, Thanks for the response. > 1. In the public interface section, could we spell out the configurations that we are changing with this KIP? The name does not change but the semantic is so it is good to be clear. Done > 2. In the proposed changes section, I would rather mention the config

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #859

See

[GitHub] [kafka-site] cadonna merged pull request #405: Add Bruno's public key to KEYS

cadonna merged PR #405: URL: https://github.com/apache/kafka-site/pull/405 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.

Re: [VOTE] KIP-813 Shared State Stores

Hey Daan, The final step in the KIP is to declare the KIP accepted like this: The KIP-813 vote has passed with: binding +1s (John, Matthias, Bill) non-binding +1s (Daan, Federico) Thanks, John (PS: can you also update the wiki to say the Kip is accepted?) On Tue, Apr 12, 2022, at 02:51, Daan

RE: [DISCUSS] KIP-613: Add end-to-end latency metrics to Streams

CONFIDENTIAL & RESTRICTED Hello, I hope that you are doing well. I have a quick question please, I created a Kafka streams dashboard which works well, expect that we got a negative latency for record end2end latency with this metric (kafka_streams_stream_processor_node_metrics_record_e2e_laten

[GitHub] [kafka-site] bbejeck merged pull request #404: Add atruvia to powered-by

bbejeck merged PR #404: URL: https://github.com/apache/kafka-site/pull/404 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@kafka.apache.

[GitHub] [kafka-site] bbejeck commented on pull request #404: Add atruvia to powered-by

bbejeck commented on PR #404: URL: https://github.com/apache/kafka-site/pull/404#issuecomment-1099286874 @PhilippB21 thanks for the addition to the powered-by page -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

maxParallelForks while running tests

Hi, I came across this issue which has discussion about capping maxParallelForks while running tests. https://issues.apache.org/jira/browse/KAFKA-2613 Is this still the case? Thanks, Unmesh

[jira] [Resolved] (KAFKA-13823) Remove "max" version level from finalized features

[ https://issues.apache.org/jira/browse/KAFKA-13823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-13823. -- Fix Version/s: 3.3.0 Resolution: Fixed > Remove "max" version level from finalized feat

[jira] [Created] (KAFKA-13830) Introduce metadata.version in KRaft

David Arthur created KAFKA-13830: Summary: Introduce metadata.version in KRaft Key: KAFKA-13830 URL: https://issues.apache.org/jira/browse/KAFKA-13830 Project: Kafka Issue Type: Sub-task

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #860

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #861

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.2 #30

See

Re: [VOTE] KIP-825: introduce a new API to control when aggregated results are produced

Hello Hao, Just a bit further suggestion to align with KIP-444 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-444%3A+Augment+metrics+for+Kafka+Streams): in the suppression processor node we have an existing metric as follows: suppression-emit (rate | total) So I'm feeling maybe we can

[jira] [Resolved] (KAFKA-13242) KRaft Controller doesn't handle UpdateFeaturesRequest

[ https://issues.apache.org/jira/browse/KAFKA-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming resolved KAFKA-13242. Resolution: Fixed > KRaft Controller doesn't handle UpdateFeaturesRequest > --

Re: maxParallelForks while running tests

Hi Unmesh, Are you running into any issue with that? So far, the `maxParallelForks` can be set via gradle argument: https://github.com/apache/kafka/blob/trunk/build.gradle#L78 And in Jenkins, it looks like we default to 2. https://github.com/apache/kafka/blob/trunk/Jenkinsfile#L40 Thank you. Lu

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #862

See

[jira] [Resolved] (KAFKA-13653) Proactively discover alive brokers from bootstrap server lists when all nodes are down

[ https://issues.apache.org/jira/browse/KAFKA-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13653. --- Resolution: Duplicate > Proactively discover alive brokers from bootstrap server lists when all node

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #863

See