[GitHub] kafka pull request #2676: MINOR: Suppress an inappropriate warning in Mirror...

2017-03-11 Thread takebayashi
GitHub user takebayashi opened a pull request: https://github.com/apache/kafka/pull/2676 MINOR: Suppress an inappropriate warning in MirrorMaker Though MirrorMaker uses the `producer.type` value of the producer properties, ProducerConfig show the warning: `The configuration 'produce

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

2017-03-11 Thread Eric Bolinger (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906349#comment-15906349 ] Eric Bolinger commented on KAFKA-3806: -- People learn of the interaction between log.r

[jira] [Created] (KAFKA-4887) Enabling caching on a persistent window store breaks support for duplicate insertion

2017-03-11 Thread Elias Levy (JIRA)
Elias Levy created KAFKA-4887: - Summary: Enabling caching on a persistent window store breaks support for duplicate insertion Key: KAFKA-4887 URL: https://issues.apache.org/jira/browse/KAFKA-4887 Project:

Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API

2017-03-11 Thread Matthias J. Sax
Thanks for your feedback Guozhang. 1) There are multiple ways to do this. Let me know what you think about all options: (a) I updated the KIP to this: > public final class Source implements Node { > public final String name; > // topicNames and topicPattern are mutually excl

[jira] [Created] (KAFKA-4886) In a topic with partitions with replication factor of 1, when a partition is added AFTER a new broker is added, Kafka does not always assign new partition to the new brok

2017-03-11 Thread Prasanna Kumar P.V. (JIRA)
Prasanna Kumar P.V. created KAFKA-4886: -- Summary: In a topic with partitions with replication factor of 1, when a partition is added AFTER a new broker is added, Kafka does not always assign new partition to the new broker.

Re: [DISCUSS] KIP-82 - Add Record Headers

2017-03-11 Thread Abhishek Agarwal
Bumping up this thread. Is there a final verdict on this KIP? On Sat, Dec 3, 2016 at 2:29 AM, Gwen Shapira wrote: > Woah, I wasn't aware this is something we'll do. It wasn't in the KIP, > right? > > I guess we could do it the same way ACLs currently work. > I had in mind something that will all

[jira] [Created] (KAFKA-4885) processstreamwithcachedstatestore streams benchmark failed

2017-03-11 Thread Eno Thereska (JIRA)
Eno Thereska created KAFKA-4885: --- Summary: processstreamwithcachedstatestore streams benchmark failed Key: KAFKA-4885 URL: https://issues.apache.org/jira/browse/KAFKA-4885 Project: Kafka Issu