Jenkins build is back to normal : kafka-trunk-jdk7 #3092

2018-01-11 Thread Apache Jenkins Server
See

Re: [VOTE] KIP-243: Make ProducerConfig and ConsumerConfig constructors public

2018-01-11 Thread Matthias J. Sax
One follow up, addressing Ewen's comment: It seems an older KIP update was not reflected (maybe I forgot to hit save or only though I updated the KIP -- sorry for that). The new API will be > public ProducerConfig(Properties props); > public ProducerConfig(Map props); > public ConsumerConfig(Prop

Re: [VOTE] KIP-243: Make ProducerConfig and ConsumerConfig constructors public

2018-01-11 Thread Matthias J. Sax
+1 I am closing this vote as accepted with 5 non-binding +1 (Ted, Vahid, Tom, Bill, Matthias) and 3 binding +1 (Guozhang, Jason, Ewen) votes. Thanks a lot. -Matthias On 1/8/18 1:29 PM, Matthias J. Sax wrote: > We cannot simply change to without breaking a lot of code and > making it a nightm

[DISCUSS] KIP-247: Add public test utils for Kafka Streams

2018-01-11 Thread Matthias J. Sax
Dear Kafka community, I want to propose KIP-247 to add public test utils to the Streams API. The goal is to simplify testing of Kafka Streams applications. Please find details in the wiki: https://cwiki.apache.org/confluence/display/KAFKA/KIP-247%3A+Add+public+test+utils+for+Kafka+Streams This i

Re: [DISCUSS] KIP-232: Detect outdated metadata by adding ControllerMetadataEpoch field

2018-01-11 Thread Dong Lin
Hey Jun, Thanks much. I agree that we can not rely on committed offsets to be always deleted when we delete topic. So it is necessary to use a per-partition epoch that does not change unless this partition is deleted. I also agree that it is very nice to be able to uniquely identify a message with

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

2018-01-11 Thread Apache Jenkins Server
See Changes: [jason] KAFKA-6250: Use existing Kafka Connect internal topics without requiring -- [...truncated 1.92 MB...] org.apache.kafka.connect.runtime.Transformation

High CPU

2018-01-11 Thread peter holm
https://issues.apache.org/jira/browse/KAFKA-3159 Also in version 1.0.0 - and doing sleep between pools is heartly a reasonable workaround. any fixes upcoming ? Peter

[jira] [Resolved] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist

2018-01-11 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6250. Resolution: Fixed Assignee: Gavrie Philipson > Kafka Connect requires permission to cr

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

2018-01-11 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-6265: Add #queryableStoreName() to GlobalKTable -- [...truncated 3.78 MB...] org.apache.kafka.streams.kstream.internals.KTableImplTest > sh

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

2018-01-11 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-6265: Add #queryableStoreName() to GlobalKTable -- [...truncated 401.69 KB...] kafka.tools.ConsoleProducerTest > testParseKeyProp STARTED ka

[jira] [Created] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results

2018-01-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6443: Summary: KTable involved in multiple joins could result in duplicate results Key: KAFKA-6443 URL: https://issues.apache.org/jira/browse/KAFKA-6443 Project: Kafka

[jira] [Created] (KAFKA-6442) Catch 22 with cluster rebalancing

2018-01-11 Thread Andreas (JIRA)
Andreas created KAFKA-6442: -- Summary: Catch 22 with cluster rebalancing Key: KAFKA-6442 URL: https://issues.apache.org/jira/browse/KAFKA-6442 Project: Kafka Issue Type: Bug Reporter: And

Call for Presentations FOSS Backstage open

2018-01-11 Thread Isabel Drost-Fromm
Hi, As announced on Berlin Buzzwords we (that is Isabel Drost-Fromm, Stefan Rudnitzki as well as the eventing team over at newthinking communications GmbH) are working on a new conference in summer in Berlin. The name of this new conference will be "FOSS Backstage". Backstage comprises all things