join kafka

join kafka

Jenkins build is back to normal : kafka-trunk-jdk11 #840

See

[jira] [Created] (KAFKA-8958) Fix Kafka Streams JavaDocs with regard to used Serdes

Matthias J. Sax created KAFKA-8958: -- Summary: Fix Kafka Streams JavaDocs with regard to used Serdes Key: KAFKA-8958 URL: https://issues.apache.org/jira/browse/KAFKA-8958 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk8 #3928

See Changes: [github] KAFKA-8907; Return topic configs in CreateTopics response (KIP-525) -- [...truncated 6.86 MB...]

Build failed in Jenkins: kafka-trunk-jdk11 #839

See Changes: [manikumar] KAFKA-6883: Add toUpperCase support to sasl.kerberos.principal.to.local [github] KAFKA-8319: Make KafkaStreamsTest a non-integration test class (#7382) [wangguoz] KAFKA-8934: Create

Re: [DISCUSS] KIP-515: Reorganize checkpoint system in log cleaner to be per partition

Hi Jason, That actually sounds like a pretty good idea to me. No doubt if we use this approach, then some comments need to be added that indicates this. But all things considered, I think its not bad at all. I definitely agree with you on that its a little hacky, but it works. Cheers, Richard

Build failed in Jenkins: kafka-2.1-jdk8 #231

See Changes: [matthias] KAFKA-7895: Revert suppress changelog bugfix for 2.1 (#7373) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building

Jenkins build is back to normal : kafka-trunk-jdk11 #838

See

[jira] [Resolved] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8427. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang Resolution: Fixed Should have

[jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8319. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang (was: Bill Bejeck) Resolution:

[jira] [Created] (KAFKA-8957) Improve docs about `min.isr.` and `acks=all`

Matthias J. Sax created KAFKA-8957: -- Summary: Improve docs about `min.isr.` and `acks=all` Key: KAFKA-8957 URL: https://issues.apache.org/jira/browse/KAFKA-8957 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name

[ https://issues.apache.org/jira/browse/KAFKA-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6883. -- Fix Version/s: 2.4.0 Resolution: Fixed Issue resolved by pull request 7375

[jira] [Created] (KAFKA-8956) Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach

Colin McCabe created KAFKA-8956: --- Summary: Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach Key: KAFKA-8956 URL: https://issues.apache.org/jira/browse/KAFKA-8956

[jira] [Created] (KAFKA-8955) Add an AbstractResponse#errorCounts method that takes a stream or iterable

Colin McCabe created KAFKA-8955: --- Summary: Add an AbstractResponse#errorCounts method that takes a stream or iterable Key: KAFKA-8955 URL: https://issues.apache.org/jira/browse/KAFKA-8955 Project:

Re: [Discuss] - KIP-532 - Add KStream#toTable to the Streams DSL

Looks good to me! I have no further comments. Thanks again for the KIP, Aishwarya! -John On Fri, Sep 27, 2019 at 10:11 AM aishwarya kumar wrote: > > Hello John, > > Thank you for pointing this out to me, to maintain consistency across API's > it does make sense to allow users to define custom

Re: [DISCUSS] KIP-424: Allow suppression of intermediate events based on wall clock time

Hey Jonathan, What's the status of this KIP? I was just in a discussion about suppress, and it sparked my memory of this idea. Thanks, -John On Mon, Mar 11, 2019 at 4:39 PM John Roesler wrote: > > Thanks for the response, Matthias, I agree on both of these points. > > I didn't mean to question

Re: [Discuss] - KIP-532 - Add KStream#toTable to the Streams DSL

Hello John, Thank you for pointing this out to me, to maintain consistency across API's it does make sense to allow users to define custom names for their processors. I've made the change in the KIP:

Re: [VOTE] KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum

On Thu, Sep 26, 2019 at 2:16 PM Jun Rao wrote: > [...] > 100. It would be useful to think through how to support SASL scram in the > new world. If the only broker listener is SASL scram, we need to bootstrap > the scram credential in each broker before we can start the broker. > Currently, this

Re: Status of user Admin API for quotas

Hi Viktor and Colin, Thanks for the update. Viktor, if you publish your KIP after summit then we can at least what comes out of the discussion. Distinguishing between normal ISR traffic and reassignment traffic would be nice (if that's something your KIP would enable), and any such distinction

[jira] [Created] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API

David Jacot created KAFKA-8954: -- Summary: Topic existence check is wrongly implemented in the DeleteOffset API Key: KAFKA-8954 URL: https://issues.apache.org/jira/browse/KAFKA-8954 Project: Kafka

[jira] [Created] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

Matthias J. Sax created KAFKA-8953: -- Summary: Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor Key: KAFKA-8953 URL: https://issues.apache.org/jira/browse/KAFKA-8953 Project:

[jira] [Created] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0

Namrata Kokate created KAFKA-8952: - Summary: Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 Key: KAFKA-8952 URL: