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

See Changes: [ismael] KAFKA-6430: Add buffer for gzip streams (#4537) [github] MINOR: Enable deep-iteration to print data in DumpLogSegments (#4396) [jason] KAFKA-6568; Log cleaner should check partition state

Build failed in Jenkins: kafka-1.1-jdk7 #48

See Changes: [jason] KAFKA-6568; Log cleaner should check partition state before removal from [jason] MINOR: Fix bug introduced by adding batch.size without default in --

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

See Changes: [jason] KAFKA-6568; Log cleaner should check partition state before removal from -- [...truncated 372.98 KB...] kafka.controller.ZookeeperClientTest >

Build failed in Jenkins: kafka-0.11.0-jdk7 #358

See Changes: [jason] KAFKA-6568; Log cleaner should check partition state before removal from -- [...truncated 977.88 KB...]

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

See Changes: [jason] KAFKA-6568; Log cleaner should check partition state before removal from [jason] MINOR: Fix bug introduced by adding batch.size without default in

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

See Changes: [jason] KAFKA-6568; Log cleaner should check partition state before removal from [jason] MINOR: Fix bug introduced by adding batch.size without default in --

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

See Changes: [mjsax] KAFKA-6424: QueryableStateIntegrationTest#queryOnRebalance should accept [github] MINOR: Fix Streams EOS system tests (#4572) [mjsax] KAFKA-6536: Adding versions for japicmp-maven-plugin

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

See Changes: [matthias] MINOR: Fix Streams EOS system tests (#4572) [matthias] KAFKA-6536: Adding versions for japicmp-maven-plugin and -- [...truncated 187.95 KB...]

[jira] [Resolved] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6568. Resolution: Fixed Fix Version/s: 1.0.2 0.11.0.3 >

[jira] [Resolved] (KAFKA-6228) Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure

[ https://issues.apache.org/jira/browse/KAFKA-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6228. --- Resolution: Cannot Reproduce > Intermittent test failure in >

[jira] [Resolved] (KAFKA-6430) Improve Kafka GZip compression performance

[ https://issues.apache.org/jira/browse/KAFKA-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6430. Resolution: Fixed Fix Version/s: 1.1.0 > Improve Kafka GZip compression performance >

Jenkins build is back to normal : kafka-1.1-jdk7 #45

See

[jira] [Resolved] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4186. Resolution: Fixed We did some test rework and this did not fail for a while. Closing this

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

See Changes: [jason] MINOR: Make it explicit in consumer docs that poll() is needed for [jason] MINOR: Fix typos in kafka.py (#4581) -- [...truncated 448.95 KB...]

[jira] [Resolved] (KAFKA-5430) new consumers getting data for revoked partitions

[ https://issues.apache.org/jira/browse/KAFKA-5430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5430. Resolution: Fixed I think this issue was fixed in KAFKA-5154. Please reopen if you think it

Build failed in Jenkins: kafka-1.1-jdk7 #44

See Changes: [jason] MINOR: Make it explicit in consumer docs that poll() is needed for -- [...truncated 411.95 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

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

See

[jira] [Created] (KAFKA-6569) Reflection in OffsetIndex and TimeIndex construction

Kyle Ambroff-Kao created KAFKA-6569: --- Summary: Reflection in OffsetIndex and TimeIndex construction Key: KAFKA-6569 URL: https://issues.apache.org/jira/browse/KAFKA-6569 Project: Kafka

Recovering from disk full

Hi There, What is the process to recover from a scenario where Kafka service is down due to one of the logs dir disk is full? We can delete the topic partitions on the directory since many of the topics are not required. Any input is much appreciated. Thanks, Biju

Build failed in Jenkins: kafka-1.1-jdk7 #43

See Changes: [jason] MINOR: Free sends in MultiSend as they complete (#4574) -- [...truncated 411.92 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Re: [DISCUSS] KIP-213 Support non-key joining in KTable

Update: I want to give a quick update on what I found porting the 0.10 version towards 1.0. 1. It is difficult to provide a stock CombinedKey Serde. We effectively wrap 2 serdes for the key. We do not have good topic names to feed into the Avro Serde for K1 and K2 for the same topic.

Re: [VOTE] 1.0.1 RC1

Ran tests from source and quickstart with binaries +1 (non-binding) On Fri, Feb 16, 2018 at 6:05 AM, Jason Gustafson wrote: > +1. Verified artifacts and ran quickstart. Thanks Ewen! > > -Jason > > On Thu, Feb 15, 2018 at 1:42 AM, Rajini Sivaram >

Re: 1.1 release progress

Hi Becket, Thanks for letting me know. Damian On Fri, 16 Feb 2018 at 01:48 Ismael Juma wrote: > Sounds good. Thanks Becket. > > Ismael > > On 15 Feb 2018 5:30 pm, "Becket Qin" wrote: > > > Hi Ismael, > > > > Yes, I am working on the fix. Will submit

[jira] [Resolved] (KAFKA-6537) Duplicate consumers after consumer group rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Golovanov resolved KAFKA-6537. -- Resolution: Duplicate > Duplicate consumers after consumer group rebalance >