[jira] [Created] (KAFKA-13428) server hang on shutdown

yuhuo created KAFKA-13428: - Summary: server hang on shutdown Key: KAFKA-13428 URL: https://issues.apache.org/jira/browse/KAFKA-13428 Project: Kafka Issue Type: Improvement Components: core

Re: Contributer List

Done. On 11/1/21 1:00 PM, Florin Akermann wrote: Hi, I would like to become a contributor. My Jira account username is 'aki' Thank you in advance. Florin

Re: [DISCUSS] KIP-786: Use localhost:9092 as default bootstrap-server/broker-list in client tools

Thank you Maison I have update the KIP number to KIP-789, the url has been updated to: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=191335433 Thanks Deng Ziming > On Oct 31, 2021, at 10:39 PM, Mick

[jira] [Created] (KAFKA-13427) Max connections per listener are not blocked

Ekaterina Chernousova created KAFKA-13427: - Summary: Max connections per listener are not blocked Key: KAFKA-13427 URL: https://issues.apache.org/jira/browse/KAFKA-13427 Project: Kafka

Re: Updating the Kafka clients page

Not sure. My understanding was also that you should be able to edit without special permissions. Anyway, I added you, and granted you more permissions (as required for creating a KIP). Please let us know if this fixes the problem (you might need to logout and login again to pickup the new perm

Re: Why need handle delete topic in topic change event

On Mon, Oct 11, 2021, at 03:06, 方晓兵 wrote: > Hi Team, > > I have a problem when I study kafka code in version 2.8.0. > > I see `controllerContext.removeTopic(topic)` have been called in > `TopicDeletionManager.completeDeleteTopic()`. TopicChangeHandler not > only listen to child delete but also

Re: [DISCUSS] Bringing Kafka towards Scala 3

Thanks for looking at this, Josep... I guess the way I always imagined this happening was that a Scala 3 release would become one of our two supported Scala versions. So instead of 2.12 and 2.13, we'd have 2.13 and 3.x, for some X. Do you think that approach would be practical? best, Colin On

Re: Allowing both IPv4 and IPv6 connections on the same port

Hi Matthew, I think you should create a KIP for this proposal, since it is a change to our public interfaces. Also, there are some subtle questions that we need to answer, like do the ipv4 and ipv6 interfaces that share the same port also have to share the same security protocol? best, Colin

Re: Track topic deletion state without ZK

Hi Omnia, It is not necessary to know which topics are marked for deletion in when in KRaft mode, because topic deletion happens immediately. best, Colin On Thu, Oct 28, 2021, at 06:57, Omnia Ibrahim wrote: > Hi, > > Kafka topicCommand used to report which topic is marked for deletion by > chec

Contributer List

Hi, I would like to become a contributor. My Jira account username is 'aki' Thank you in advance. Florin

Re: [VOTE] KIP-714: Client Metrics and Observability

+1 Thank you for the KIP! Our organization runs kafka at large scale in a multi-tenant configuration. We actually have many other enterprises connecting up to our system to retrieve stream data. These feeds vary greatly in volume and velocity. The peak rates are a multiplicative factor of the nom

[jira] [Created] (KAFKA-13426) Add recordMetadata to StateStoreContext

Patrick Stuedi created KAFKA-13426: -- Summary: Add recordMetadata to StateStoreContext Key: KAFKA-13426 URL: https://issues.apache.org/jira/browse/KAFKA-13426 Project: Kafka Issue Type: Impro

[jira] [Created] (KAFKA-13425) KafkaConsumer#pause() will lose its effect after groupRebalance occurs, which maybe cause data loss on the consumer side

RivenSun created KAFKA-13425: Summary: KafkaConsumer#pause() will lose its effect after groupRebalance occurs, which maybe cause data loss on the consumer side Key: KAFKA-13425 URL: https://issues.apache.org/jira/brow