Re: [ANNOUNCE] New committer: Damian Guy

Thanks everyone. Looking forward to making many more contributions On Sat, 10 Jun 2017 at 02:46, Joe Stein wrote: > Congrats! > > > ~ Joe Stein > > On Fri, Jun 9, 2017 at 6:49 PM, Neha Narkhede wrote: > > > Well deserved. Congratulations Damian! > > > > On Fri, Jun 9, 2017 at 1:34 PM Guozhang Wa

[GitHub] kafka pull request #3289: MINOR: add Yahoo benchmark to nightly runs

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3289 MINOR: add Yahoo benchmark to nightly runs You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka yahoo-benchmark Alternatively

Re: [ANNOUNCE] New committer: Damian Guy

Congrats Damian! On Sat, Jun 10, 2017 at 8:46 AM, Damian Guy wrote: > Thanks everyone. Looking forward to making many more contributions > On Sat, 10 Jun 2017 at 02:46, Joe Stein wrote: > >> Congrats! >> >> >> ~ Joe Stein >> >> On Fri, Jun 9, 2017 at 6:49 PM, Neha Narkhede wrote: >> >> > Well d

[jira] [Assigned] (KAFKA-4655) Improve test coverage of CompositeReadOnlySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-4655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4655: - Assignee: Jeyhun Karimov > Improve test coverage of CompositeReadOnlySessionStore > -

[GitHub] kafka pull request #3290: KAFKA-4655: Improve test coverage of CompositeRead...

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3290 KAFKA-4655: Improve test coverage of CompositeReadOnlySessionStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAF

[jira] [Commented] (KAFKA-4655) Improve test coverage of CompositeReadOnlySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-4655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045501#comment-16045501 ] ASF GitHub Bot commented on KAFKA-4655: --- GitHub user jeyhunkarimov opened a pull req

[GitHub] kafka pull request #3291: KAFKA-4659: Improve test coverage of CachingKeyVal...

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3291 KAFKA-4659: Improve test coverage of CachingKeyValueStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4659

[jira] [Assigned] (KAFKA-4659) Improve test coverage of CachingKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4659: - Assignee: Jeyhun Karimov > Improve test coverage of CachingKeyValueStore > --

[jira] [Commented] (KAFKA-4659) Improve test coverage of CachingKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045525#comment-16045525 ] ASF GitHub Bot commented on KAFKA-4659: --- GitHub user jeyhunkarimov opened a pull req

KIP Permission Request

Good afternoon, I am writing to request permission to create Kafka Improvement Proposal (KIP) pages on the Apache Kafka confluence. My wiki username is grantne...@hotmail.com. The KIP relates to a lag-based partition assignment strategy, similar to that proposed here

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045572#comment-16045572 ] Jun Rao commented on KAFKA-5413: Could you attach the .index file of the 2 segments too?

[GitHub] kafka pull request #3292: KAFKA-4656: Improve test coverage of CompositeRead...

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3292 KAFKA-4656: Improve test coverage of CompositeReadOnlyKeyValueStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KA

[jira] [Commented] (KAFKA-4656) Improve test coverage of CompositeReadOnlyKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045583#comment-16045583 ] ASF GitHub Bot commented on KAFKA-4656: --- GitHub user jeyhunkarimov opened a pull req

[jira] [Assigned] (KAFKA-4656) Improve test coverage of CompositeReadOnlyKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4656: - Assignee: Jeyhun Karimov > Improve test coverage of CompositeReadOnlyKeyValueStore >

??????Re?? [DISCUSS] KIP-148: Add a connect timeout for client

-- -- ??: "";<254479...@qq.com>; : 2017??6??4??(??) 6:05 ??: "dev"; : Re?? [DISCUSS] KIP-148: Add a connect timeout for client >I guess one obvious question is, how does this interact with retries? >Does it result in

[VOTE] KIP-148: Add a connect timeout for client

Hi All, Since we all reach the consensus, I want to start a voting for this KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-148%3A+Add+a+connect+timeout+for+client Thanks, David

[jira] [Created] (KAFKA-5426) One second delay in kafka-console-producer

Francisco created KAFKA-5426: Summary: One second delay in kafka-console-producer Key: KAFKA-5426 URL: https://issues.apache.org/jira/browse/KAFKA-5426 Project: Kafka Issue Type: Bug Co

[GitHub] kafka pull request #3293: KAFKA-4658: Improve test coverage InMemoryKeyValue...

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3293 KAFKA-4658: Improve test coverage InMemoryKeyValueLoggedStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-46

[jira] [Assigned] (KAFKA-4658) Improve test coverage InMemoryKeyValueLoggedStore

[ https://issues.apache.org/jira/browse/KAFKA-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4658: - Assignee: Jeyhun Karimov > Improve test coverage InMemoryKeyValueLoggedStore > --

[jira] [Commented] (KAFKA-4658) Improve test coverage InMemoryKeyValueLoggedStore

[ https://issues.apache.org/jira/browse/KAFKA-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045602#comment-16045602 ] ASF GitHub Bot commented on KAFKA-4658: --- GitHub user jeyhunkarimov opened a pull req

[jira] [Commented] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045633#comment-16045633 ] Mike Fagan commented on KAFKA-5424: --- Thanks, I am seeing this running a Kafka 0.10.0.2.5

[jira] [Commented] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045634#comment-16045634 ] Mickael Maison commented on KAFKA-5424: --- I was able to reproduce when running 0.10.0

[GitHub] kafka pull request #3294: KAFKA-4653: Improve test coverage of RocksDBStore

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3294 KAFKA-4653: Improve test coverage of RocksDBStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4653 Alternat

[jira] [Commented] (KAFKA-4653) Improve test coverage of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045635#comment-16045635 ] ASF GitHub Bot commented on KAFKA-4653: --- GitHub user jeyhunkarimov opened a pull req

[jira] [Assigned] (KAFKA-4653) Improve test coverage of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4653: - Assignee: Jeyhun Karimov > Improve test coverage of RocksDBStore > --

[jira] [Commented] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045676#comment-16045676 ] Evgeny Veretennikov commented on KAFKA-5145: It seems like ProcessorNode.close

[GitHub] kafka pull request #3295: KAFKA-5418: ZkUtils.getAllPartitions() may fail if...

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/3295 KAFKA-5418: ZkUtils.getAllPartitions() may fail if a topic is marked for deletion Skip topics that don't have any partitions in zkUtils.getAllPartitions() You can merge this pull request into a Gi

[jira] [Commented] (KAFKA-5418) ZkUtils.getAllPartitions() may fail if a topic is marked for deletion

[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045678#comment-16045678 ] ASF GitHub Bot commented on KAFKA-5418: --- GitHub user mimaison opened a pull request:

[GitHub] kafka pull request #3296: KAFKA-3123: Follower Broker cannot start if offset...

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/3296 KAFKA-3123: Follower Broker cannot start if offsets are already out o… …f range From https://github.com/apache/kafka/pull/1716#discussion_r112000498, ensure the cleaner is restarted if

[jira] [Commented] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

[ https://issues.apache.org/jira/browse/KAFKA-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045695#comment-16045695 ] ASF GitHub Bot commented on KAFKA-3123: --- GitHub user mimaison opened a pull request:

[jira] [Resolved] (KAFKA-4661) Improve test coverage UsePreviousTimeOnInvalidTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4661. -- Resolution: Fixed Fix Version/s: 0.11.1.0 Issue resolved by pull request 3288 [https://gi

[GitHub] kafka pull request #3288: KAFKA-4661: Improve test coverage UsePreviousTimeO...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3288 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-4661) Improve test coverage UsePreviousTimeOnInvalidTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045721#comment-16045721 ] ASF GitHub Bot commented on KAFKA-4661: --- Github user asfgit closed the pull request

Re: KIP Permission Request

Added. Thanks. Guozhang On Sat, Jun 10, 2017 at 1:28 AM, Grant Neale wrote: > Good afternoon, > > > I am writing to request permission to create Kafka Improvement Proposal > (KIP) pages on the Apache Kafka confluence. > > > My wiki username is grantne...@hotmail.com. > > > The KIP relates to a

[jira] [Created] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

Jason Gustafson created KAFKA-5427: -- Summary: Transactional producer cannot find coordinator when trying to abort transaction after error Key: KAFKA-5427 URL: https://issues.apache.org/jira/browse/KAFKA-5427

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

See

[jira] [Commented] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

[ https://issues.apache.org/jira/browse/KAFKA-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045748#comment-16045748 ] ASF GitHub Bot commented on KAFKA-5427: --- GitHub user hachikuji opened a pull request

[GitHub] kafka pull request #3297: KAFKA-5427: Transactional producer should allow Fi...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3297 KAFKA-5427: Transactional producer should allow FindCoordinator in error state You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafk

Re: Reg: [VOTE] KIP 157 - Add consumer config options to streams reset tool

Bharat, I think we already have 3 committers voted on this KIP, could you conclude the thread? Guozhang On Fri, Jun 2, 2017 at 3:44 PM, Jason Gustafson wrote: > Thanks. +1 > > On Thu, Jun 1, 2017 at 9:40 PM, Matthias J. Sax > wrote: > > > +1 > > > > Thanks for updating the KIP! > > > > -Mat

[jira] [Commented] (KAFKA-3129) Console producer issue when request-required-acks=0

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045812#comment-16045812 ] Pankaj commented on KAFKA-3129: --- [~cotedm], [~ijuma], [~vahid] I am also facing the same iss