Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #47

See Changes: [github] KAFKA-10133: MM2 readme update on config (#9215) [github] KAFKA-10259: KIP-554 Broker-side SCRAM Config API (#9032) -- [...truncated 6.

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

Hi Colin, Thanks for the response. >>If the start time is not specified in the request, then the network time is excluded from the heartbeat time. The most common implementation pattern I see (looking at Google Chubby sessions, Zookeeper sessions, etcd lease implementation, LogCabin session and Doc

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #46

See Changes: [github] KAFKA-10259: KIP-554 Broker-side SCRAM Config API (#9032) -- [...truncated 6.52 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #47

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #45

See

Re: [VOTE] KIP-663: API to Start and Shut Down Stream Threads and to Request Closing of Kafka Streams Clients

Hi Sophie, Uh, oh, it's never a good sign when the discussion moves into the vote thread :) I agree with you, it seems like a good touch for removeStreamThread() to return the name of the thread that got removed, rather than a boolean flag. Maybe the return value would be `null` if there is no th

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi all, This conversation sounds good to me so far. Sophie raised a concern before that changing the state machine would break state restore listeners. This is true, and we actually have not changed the main state machine in a long time. The last change I remember was that we used to go "CREATED

[jira] [Resolved] (KAFKA-10259) KIP-554: Add Broker-side SCRAM Config API

[ https://issues.apache.org/jira/browse/KAFKA-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-10259. -- Fix Version/s: 2.7.0 Reviewer: Colin McCabe Resolution: Fixed > KIP-554: Add B

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

> Colin wrote: > > The reason for including LeaseStartTimeMs in the request is to ensure > > that the time required to communicate with the controller gets included in > > the lease time. Since requests can potentially be delayed in the network > > for a long time, this is important. On Mon, Aug

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #46

See Changes: [github] KAFKA-10133: MM2 readme update on config (#9215) -- [...truncated 3.28 MB...] org.apache.kafka.streams.test.OutputVerifierTest > should

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #44

See Changes: [github] KAFKA-10314: KafkaStorageException on reassignment when offline log directories exist (#9122) -- [...truncated 3.25 MB...] org.apache.k

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #45

See Changes: [github] KAFKA-10314: KafkaStorageException on reassignment when offline log directories exist (#9122) -- [...truncated 3.28 MB...] org.apache.k

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun, Thanks for your thorough review and comments. Please find the inline replies below. 600. The topic deletion logic needs more details. 600.1 The KIP mentions "The controller considers the topic partition is deleted only when it determines that there are no log segments for that topic partit

Re: Apply for JIRA contributor authority

Done. Thanks for your interest in Apache Kafka! On Fri, Sep 4, 2020 at 4:54 PM 季伟 wrote: > > Hi, > I want to contribute to Apache Kafka, > Would you please offer me the contributor permission? > My JIRA ID is jiweiautohome. > > -- >

[jira] [Resolved] (KAFKA-10314) KafkaStorageException on reassignment when offline log directories exist

[ https://issues.apache.org/jira/browse/KAFKA-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10314. Fix Version/s: 2.7.0 Resolution: Fixed > KafkaStorageException on reassignment when

Apply for JIRA contributor authority

Hi, I want to contribute to Apache Kafka, Would you please offer me the contributor permission? My JIRA ID is jiweiautohome. --

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi Sophie, Thanks for the detailed explanation. I agree from a user standpoint, I don't think there is any use-case to take any separate action in case of GLOBAL_RESTORING and RESTORING phase.  So, internally in the code we can handle the cases as Matthiasexplained above and we can discuss tho

[DISCUSS] KIP idea: Support of multipart messages

Hello, I would like to get your opinions on this KIP idea. In short it will allow to transfer messages of bigger size than allowed by the broker. https://docs.google.com/document/d/1cKBNxPkVVENly9YczYXsVDVWwrCdRq3G_cja5s2QDQg/edit?usp=sharing If all that makes sense, I'll create a full fledged