[jira] [Resolved] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing

2016-11-13 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxi resolved KAFKA-4398. - Resolution: Not A Bug > offsetsForTimes returns false starting offset when timestamp of messages are > not monoto

Re?? [DISCUSS] KIP-68 Add a consumed log retention before log retention

2016-11-13 Thread ????????
Hi Becket, If using the trim.on.offset.commit parameter, it will help to quickly trim the log, but other consumer group's consumer may find the messages are trimmed. We still need to coordinate many consumer groups to trim the log, it seems difficult for the single consumer to do it. The

[jira] [Created] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashio

2016-11-13 Thread Jun Yao (JIRA)
Jun Yao created KAFKA-4402: -- Summary: Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashion" Key: KAFKA-4402

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662147#comment-15662147 ] Ewen Cheslack-Postava commented on KAFKA-4401: -- [~becket_qin] We've already d

Re: [VOTE] KIP-89: Allow sink connectors to decouple flush and offset commit

2016-11-13 Thread Gwen Shapira
+1 (binding) On Nov 9, 2016 2:17 PM, "Shikhar Bhushan" wrote: > Hi, > > I would like to initiate a vote on KIP-89 > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 89%3A+Allow+sink+connectors+to+decouple+flush+and+offset+commit > > Best, > > Shikhar >

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662153#comment-15662153 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Which code are you

[jira] [Updated] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashio

2016-11-13 Thread Jun Yao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Yao updated KAFKA-4402: --- Description: >From this code comments, it is said that Kafka client Producer's >DefaultPartitioner will do r

[GitHub] kafka pull request #2128: KAFKA-4402: make the KafkaProducer true round robi...

2016-11-13 Thread yaojuncn
GitHub user yaojuncn opened a pull request: https://github.com/apache/kafka/pull/2128 KAFKA-4402: make the KafkaProducer true round robin per topic You can merge this pull request into a Git repository by running: $ git pull https://github.com/yaojuncn/kafka KAFKA-4402-client

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662157#comment-15662157 ] ASF GitHub Bot commented on KAFKA-4402: --- GitHub user yaojuncn opened a pull request:

[jira] [Created] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4403: Summary: Update KafkaBasedLog to use new endOffsets consumer API Key: KAFKA-4403 URL: https://issues.apache.org/jira/browse/KAFKA-4403 Project: Kafka

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Jun Yao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662168#comment-15662168 ] Jun Yao commented on KAFKA-4402: Hi, Ewen, I updated the description, I am looking at the

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662198#comment-15662198 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Sorry, missed that

[jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fash

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662197#comment-15662197 ] Ewen Cheslack-Postava commented on KAFKA-4402: -- [~Jun Yao] Sorry, missed that

Re: Upgrading from kafka-0.8.1.1 to kafka-0.9.0.1

2016-11-13 Thread Ewen Cheslack-Postava
The errors you're seeing sound like an issue where you updated the artifact but didn't recompile against the newer Scala version. Did you recompile or just replace the Kafka jar with a newer one? -Ewen On Wed, Nov 9, 2016 at 4:31 PM, Divyajothi Baskaran wrote: > Hi, > For the past 6 months,I am

[jira] [Commented] (KAFKA-4021) system tests need to enable trace level logging for controller and state-change log

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662381#comment-15662381 ] Ewen Cheslack-Postava commented on KAFKA-4021: -- [~junrao] Is this actually re

[jira] [Resolved] (KAFKA-3967) Excessive Network IO between Kafka brokers

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3967. -- Resolution: Invalid [~Krishna82] Closing this for now since we haven't heard bac

[jira] [Created] (KAFKA-4404) Add knowledge of sign to numeric schema types

2016-11-13 Thread Andy Bryant (JIRA)
Andy Bryant created KAFKA-4404: -- Summary: Add knowledge of sign to numeric schema types Key: KAFKA-4404 URL: https://issues.apache.org/jira/browse/KAFKA-4404 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

2016-11-13 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15662738#comment-15662738 ] Ewen Cheslack-Postava commented on KAFKA-3959: -- [~granthenke] [~onurkaraman]