[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

2017-01-04 Thread Michael Andre Pearce (IG) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799599#comment-15799599 ] Michael Andre Pearce (IG) commented on KAFKA-4497: -- Btw, we are using act

[GitHub] kafka pull request #2312: Kafka 960 metrics upgrade

2017-01-04 Thread andreinechaev
GitHub user andreinechaev opened a pull request: https://github.com/apache/kafka/pull/2312 Kafka 960 metrics upgrade Replaced outdated yammer.metrics with codahale.metrics 3.0.0. You can merge this pull request into a Git repository by running: $ git pull https://github.com/an

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

2017-01-04 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799617#comment-15799617 ] Ismael Juma commented on KAFKA-4497: Yes, the plan is to include the fix in Confluent

[jira] [Work started] (KAFKA-4575) Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in consuming messages after resuming source connector

2017-01-04 Thread Shikhar Bhushan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4575 started by Shikhar Bhushan. -- > Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in

Re: KIP-103: Separation of Internal and External traffic

2017-01-04 Thread Ismael Juma
Thanks for the review Jun. Replies follow. 1. That's a very good point. Adding a prefix to the JAAS entry name with a fallback to the name without the prefix is consistent with how the other configs are handled, so I'll update the KIP to mention that. 2. That was a typo, thanks for catching it. I

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-04 Thread Tom DeVoe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799720#comment-15799720 ] Tom DeVoe commented on KAFKA-4477: -- We have been running 0.10.1.1 since 12/22 and have no

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-04 Thread Michael Andre Pearce (IG) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799732#comment-15799732 ] Michael Andre Pearce (IG) commented on KAFKA-4477: -- We haven't seen this

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-04 Thread Michael Andre Pearce (IG) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799732#comment-15799732 ] Michael Andre Pearce (IG) edited comment on KAFKA-4477 at 1/4/17 11:44 PM: -

Re: KIP-103: Separation of Internal and External traffic

2017-01-04 Thread Ismael Juma
I updated the KIP to cover point 1 as well. If there are no additional comments, I intend to start a vote thread within a day or two. Thanks, Ismael On Wed, Jan 4, 2017 at 11:30 PM, Ismael Juma wrote: > Thanks for the review Jun. Replies follow. > > 1. That's a very good point. Adding a prefix

[jira] [Updated] (KAFKA-4591) Create Topic Policy

2017-01-04 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4591: --- Description: It would be useful to be able to validate create topics requests. More details in the KI

[jira] [Updated] (KAFKA-4575) Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in consuming messages after resuming sink connector

2017-01-04 Thread Shikhar Bhushan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated KAFKA-4575: --- Summary: Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in consuming m

[jira] [Commented] (KAFKA-4575) Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in consuming messages after resuming source connector

2017-01-04 Thread Shikhar Bhushan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799807#comment-15799807 ] Shikhar Bhushan commented on KAFKA-4575: By the way, the error message is misleadi

[jira] [Commented] (KAFKA-3264) Mark the old Scala consumer and related classes as deprecated

2017-01-04 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799810#comment-15799810 ] Vahid Hashemian commented on KAFKA-3264: [~ijuma] [~ewencp] Just want to confirm i

[jira] [Work started] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

2017-01-04 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4547 started by Vahid Hashemian. -- > Consumer.position returns incorrect results for Kafka 0.10.1.0 client > ---

[GitHub] kafka pull request #2313: KAFKA-4575: ensure topic created before starting s...

2017-01-04 Thread shikhar
GitHub user shikhar opened a pull request: https://github.com/apache/kafka/pull/2313 KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink Otherwise in this test the sink task goes through the pause/resume cycle with 0 assigned part

[jira] [Commented] (KAFKA-4575) Transient failure in ConnectDistributedTest.test_pause_and_resume_sink in consuming messages after resuming sink connector

2017-01-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799820#comment-15799820 ] ASF GitHub Bot commented on KAFKA-4575: --- GitHub user shikhar opened a pull request:

Re: [VOTE] Vote for KIP-101 - Leader Epochs

2017-01-04 Thread Jun Rao
Hi, Ben, Thanks for the proposal. Looks good overall. A few comments below. 1. For LeaderEpochRequest, we need to include topic right? We probably want to follow other requests by nesting partition inside topic? For LeaderEpochResponse, do we need to return leader_epoch? I was thinking that we co

[jira] [Created] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

2017-01-04 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4593: Summary: Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException Key: KAFKA-4593 URL: https://issues.apache.org/jira/browse/KAFKA-45

[GitHub] kafka pull request #2111: throw exception when the connection is error.

2017-01-04 Thread huyanping
Github user huyanping closed the pull request at: https://github.com/apache/kafka/pull/2111 --- 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 e

[jira] [Updated] (KAFKA-4592) Kafka Producer Metrics Invalid Value

2017-01-04 Thread AJ Jwair (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] AJ Jwair updated KAFKA-4592: Description: Producer metrics Metric name: record-size-max When no records are produced during the monitori

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-01-04 Thread Sandokan Dias (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15799988#comment-15799988 ] Sandokan Dias commented on KAFKA-4477: -- We have been running 0.10.1.1 (in production)

[GitHub] kafka pull request #2314: MINOR: cleanup Kafka Streams exception classes

2017-01-04 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2314 MINOR: cleanup Kafka Streams exception classes You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka javaDocImprovements Alternatively you

[jira] [Commented] (KAFKA-1908) Split brain

2017-01-04 Thread Lixing (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800084#comment-15800084 ] Lixing commented on KAFKA-1908: --- Is the problem resolved in the version 0.9.X or later? Doe

Re: 0.10.2.0 release planning

2017-01-04 Thread Ewen Cheslack-Postava
Just to clarify this a bit, the additions made so far add the server-side handling of the new protocols. But it does not include any user-facing API changes to enable use of these features. Because of this, it's not particularly useful to users and not really worth mentioning. It'd mostly be useful

[GitHub] kafka pull request #2315: MINOR: Update JavaDoc for KTable helper interfaces

2017-01-04 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2315 MINOR: Update JavaDoc for KTable helper interfaces You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka javaDocImprovements2 Alternatively

[jira] [Created] (KAFKA-4594) Annotate integration tests and provide gradle build targets to run subsets of tests

2017-01-04 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-4594: Summary: Annotate integration tests and provide gradle build targets to run subsets of tests Key: KAFKA-4594 URL: https://issues.apache.org/jira/browse/KAFKA-4594

[jira] [Commented] (KAFKA-4558) throttling_test fails if the producer starts too fast.

2017-01-04 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800434#comment-15800434 ] Ewen Cheslack-Postava commented on KAFKA-4558: -- Number of partitions probably

[jira] [Commented] (KAFKA-3264) Mark the old Scala consumer and related classes as deprecated

2017-01-04 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800447#comment-15800447 ] Ewen Cheslack-Postava commented on KAFKA-3264: -- Seems reasonable to me -- the

[jira] [Reopened] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

2017-01-04 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxi reopened KAFKA-4295: - > kafka-console-consumer.sh does not delete the temporary group in zookeeper > ---

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

2017-01-04 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800498#comment-15800498 ] Jiangjie Qin commented on KAFKA-4497: - [~michael.andre.pearce] Sorry for the late resp

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

2017-01-04 Thread Michael Andre Pearce (IG) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15800617#comment-15800617 ] Michael Andre Pearce (IG) commented on KAFKA-4497: -- Hi [~becket_qin] Sorr

Wiki permissions

2017-01-04 Thread Dongjin Lee
Hello. I just completed a KIP for KAFKA-4514[^1] but can not create any page on the wiki. Could anyone can give me the permission? Regards, Dongjin [^1]: https://issues.apache.org/jira/browse/KAFKA-4514 -- *Dongjin Lee* *Software developer in Line+.So interested in massive-scale machine learn

<    1   2