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

2018-03-18 Thread Apache Jenkins Server
See Changes: [github] MINOR: fix flaky Streams EOS system test (#4728) -- [...truncated 3.53 MB...] kafka.network.SocketServerTest > testMaxConnectionsPerIpOverrides STAR

Re: [DISCUSS] KIP-270 A Scala wrapper library for Kafka Streams

2018-03-18 Thread Debasish Ghosh
> > > Should this be 1.2 (maybe it's even better to not put any version at > all) Actually wanted to emphasize that the support is from 1.0.0 onwards .. Should we make that explicit ? Like .. kafka-streams-scala only depends on the Scala standard library and Kafka > Streams 1.0.0+. In 1.1 re

Re: Subject: [VOTE] 1.1.0 RC3

2018-03-18 Thread Damian Guy
We have a green system test build - https://jenkins.confluent.io/job/system-test-kafka/job/1.1/43/ Thanks, Damian On Fri, 16 Mar 2018 at 22:10 Vahid S Hashemian wrote: > Hi Damian, > > Thanks for running the release. > > I tried buil

[jira] [Created] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-18 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6678: - Summary: Upgrade dependencies with later release versions Key: KAFKA-6678 URL: https://issues.apache.org/jira/browse/KAFKA-6678 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6679) Random corruption (CRC validation issues)

2018-03-18 Thread Ari Uka (JIRA)
Ari Uka created KAFKA-6679: -- Summary: Random corruption (CRC validation issues) Key: KAFKA-6679 URL: https://issues.apache.org/jira/browse/KAFKA-6679 Project: Kafka Issue Type: Bug Compon

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

2018-03-18 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Use log start offset as high watermark if current value is out of -- [...truncated 417.77 KB...] kafka.log.LogCleanerIntegrationTest > cleanerC

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

2018-03-18 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Use log start offset as high watermark if current value is out of -- [...truncated 373.48 KB...] kafka.log.BrokerCompressionTest > testBrokerSideC

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

2018-03-18 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Use log start offset as high watermark if current value is out of -- [...truncated 1.48 MB...] kafka.tools.ConsoleConsumerTest > shouldParseVa

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

2018-03-18 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Use log start offset as high watermark if current value is out of -- [...truncated 1.89 MB...] org.apache.kafka.streams.integration.RestoreIntegrat

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

2018-03-18 Thread Apache Jenkins Server
See Changes: [jason] MINOR: Use log start offset as high watermark if current value is out of -- [...truncated 3.53 MB...] kafka.zookeeper.ZooKeeperClientTest > testPipeli

[jira] [Resolved] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-03-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6486. Resolution: Fixed > TimeWindows causes unordered calls to windowed aggregation functions > -

Re: [DISCUSS] KIP-233: Simplify StreamsBuilder#addGlobalStore

2018-03-18 Thread Panuwat Anawatmongkhon
I couldn’t find this thread in mailing list. this reply is just to trigger it up so I can include it in KIP On Thu, 28 Dec 2560 at 03:07 Matthias J. Sax wrote: > @Matthias: just wanted to follow up on your question: > > I wanted to double check. If I understand the proposal, it would > repl

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

2018-03-18 Thread Jun Rao
Hi, Jan, Thanks for the discussion. Great points. Let me try to summarize the approach that you are proposing. On the broker side, we reshuffle the existing data in a topic from current partitions to the new partitions. Once the reshuffle fully catches up, switch the consumers to start consuming