Jenkins build is back to normal : kafka-1.0-jdk7 #142

See

Jenkins build is back to normal : kafka-trunk-jdk8 #2372

See

Build failed in Jenkins: kafka-trunk-jdk9 #347

See Changes: [wangguoz] KAFKA-4969: Attempt to evenly distribute load of tasks (#4410) [me] KAFKA-6018: Make KafkaFuture.Future an interface (KIP-218) [wangguoz] HOTFIX: ignore reset integration tests [mjsax] K

Build failed in Jenkins: kafka-trunk-jdk7 #3134

See Changes: [me] KAFKA-6018: Make KafkaFuture.Future an interface (KIP-218) [wangguoz] HOTFIX: ignore reset integration tests [mjsax] KAFKA-6323: punctuate with WALL_CLOCK_TIME triggered immediately (#4301) -

Build failed in Jenkins: kafka-1.0-jdk7 #141

See Changes: [wangguoz] KAFKA-4969: Attempt to evenly distribute load of tasks (#4410) -- [...truncated 1.44 MB...]

[DISCUSS] KIP-251: Allow timestamp manipulation in Processor API

Hi, I want to propose a new KIP for Kafka Streams that allows timestamp manipulation at Processor API level. https://cwiki.apache.org/confluence/display/KAFKA/KIP-251%3A+Allow+timestamp+manipulation+in+Processor+API Looking forward to your feedback. -Matthias signature.asc Description: Open

Re: Excessive Memory Usage with Compression enabled and possible resolutions

Thanks for the report. I haven't looked at the code, but it seems like we would want to do both 1 and 2. Can you please file a JIRA with 1.1.0 as the target version? Ismael On 30 Jan 2018 5:46 pm, "Kyle Tinker" wrote: > I'm using Kafka 1.0.0 and the Java producer. > > I've noticed high memory u

[jira] [Created] (KAFKA-6506) Integration or unit test for Connect REST SSL Support

Ewen Cheslack-Postava created KAFKA-6506: Summary: Integration or unit test for Connect REST SSL Support Key: KAFKA-6506 URL: https://issues.apache.org/jira/browse/KAFKA-6506 Project: Kafka

Excessive Memory Usage with Compression enabled and possible resolutions

I'm using Kafka 1.0.0 and the Java producer. I've noticed high memory usage in the producer when enabling compression (gzip or lz4). I don't observe the behavior with compression off, but with it on I'll run out of heap (2GB). Using a Java profiler, I see the data is in the KafkaLZ4BlockOutpu

Build failed in Jenkins: kafka-trunk-jdk7 #3133

See Changes: [github] KAFKA-6243: Enable dynamic updates of broker metrics reporters (#4464) [github] KAFKA-6166: Update javadoc for streams config (#4489) [jason] KAFKA-6418; AdminClient should handle empty or

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

See Changes: [jason] KAFKA-6148; ClassCastException in connectors that include kafka-clients [github] KAFKA-6242: Dynamic resize of various broker thread pools (#4471) --

[jira] [Resolved] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6018. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 403

[jira] [Resolved] (KAFKA-4029) SSL support for Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4029. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 442

[jira] [Resolved] (KAFKA-6418) AdminClient should handle empty or null topic names better

[ https://issues.apache.org/jira/browse/KAFKA-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6418. Resolution: Fixed Fix Version/s: 1.1.0 > AdminClient should handle empty or null topi

Build failed in Jenkins: kafka-trunk-jdk7 #3132

See Changes: [jason] KAFKA-6148; ClassCastException in connectors that include kafka-clients [github] KAFKA-6242: Dynamic resize of various broker thread pools (#4471) [wangguoz] KAFKA-6166: Streams configurati

Jenkins build is back to normal : kafka-trunk-jdk9 #345

See

Jenkins build is back to normal : kafka-0.11.0-jdk7 #350

See

[jira] [Resolved] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption

[ https://issues.apache.org/jira/browse/KAFKA-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6464. Resolution: Fixed Reviewer: Rajini Sivaram (was: Ismael Juma) > Base64URL encoding under JRE

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

+1 (non binding) Thanks for the KIP On Tue, Jan 30, 2018 at 9:49 AM, Manikumar wrote: > +1 (non-binding) > > On Tue, Jan 30, 2018 at 11:50 AM, Ewen Cheslack-Postava > wrote: > >> +1 (binding) >> >> On Fri, Jan 26, 2018 at 9:16 AM, Colin McCabe wrote: >> >> > +1 (non-binding) >> > >> > >> > >> >

Build failed in Jenkins: kafka-trunk-jdk7 #3131

See Changes: [rajinisivaram] KAFKA-6464: Fix Base64URL encode padding issue under JRE 1.7 (#4455) -- [...truncated 1.87 MB...] org.apache.kafka.streams.integration.EosIn

Re: [VOTE] KIP-201: Rationalising policy interfaces

This vote has been silent for a few weeks now but I think this would be a very useful feature. Did it just slip through busy inboxes or are there reasons why committers have not voted ? On Fri, Dec 1, 2017 at 10:37 AM, Tom Bentley wrote: > I have a PR for this (https://github.com/apache/kafka/pu

[jira] [Created] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

Per Steffensen created KAFKA-6505: - Summary: Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric Key: KAFKA-6505 URL: https://issues.apache.org/jira/browse/KAFKA-65

[jira] [Created] (KAFKA-6504) Connect: Some per-task-metrics not working

Per Steffensen created KAFKA-6504: - Summary: Connect: Some per-task-metrics not working Key: KAFKA-6504 URL: https://issues.apache.org/jira/browse/KAFKA-6504 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6503) Connect: Plugin scan is very slow

Per Steffensen created KAFKA-6503: - Summary: Connect: Plugin scan is very slow Key: KAFKA-6503 URL: https://issues.apache.org/jira/browse/KAFKA-6503 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

Soby Chacko created KAFKA-6502: -- Summary: Kafka streams deserialization handler not committing offsets on error records Key: KAFKA-6502 URL: https://issues.apache.org/jira/browse/KAFKA-6502 Project: Kafk

[jira] [Created] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize

Rajini Sivaram created KAFKA-6501: - Summary: Add test to verify markPartitionsForTruncation after fetcher thread pool resize Key: KAFKA-6501 URL: https://issues.apache.org/jira/browse/KAFKA-6501 Proj

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

See Changes: [wangguoz] KAFKA-3625: Add public test utils for Kafka Streams (#4402) [wangguoz] KAFKA-6451: Simplifying KStreamReduce and KStreamAggregate [github] MINOR: Code refacotring in KTable-KTable Join (

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

+1 (non-binding) On Tue, Jan 30, 2018 at 11:50 AM, Ewen Cheslack-Postava wrote: > +1 (binding) > > On Fri, Jan 26, 2018 at 9:16 AM, Colin McCabe wrote: > > > +1 (non-binding) > > > > > > > > On Fri, Jan 26, 2018, at 08:29, Ted Yu wrote: > > > +1 > > > > > > On Fri, Jan 26, 2018 at 7:00 AM, Bran

[jira] [Resolved] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-6497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pegerto Fernandez resolved KAFKA-6497. -- Resolution: Duplicate > streams#store ambiguous InvalidStateStoreException > ---