[jira] [Resolved] (KAFKA-2912) Add error code 4 (InvalidFetchSize) to Errors.java

[ https://issues.apache.org/jira/browse/KAFKA-2912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2912. Resolution: Fixed Assignee: Grant Henke (was: jin xing) Fix Version/s: 0.10.

[jira] [Updated] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

[ https://issues.apache.org/jira/browse/KAFKA-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3580: --- Labels: (was: label) Assignee: Manikumar Reddy Status: Patch Available (was: Ope

[jira] [Commented] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

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

[GitHub] kafka pull request: KAFKA-3580; improve error logging in ReplicaFe...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1237 KAFKA-3580; improve error logging in ReplicaFetchThread You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka KAFKA-3580 Alternativel

[jira] [Comment Edited] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247198#comment-15247198 ] Jiangjie Qin edited comment on KAFKA-3565 at 4/19/16 5:19 AM: --

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247198#comment-15247198 ] Jiangjie Qin commented on KAFKA-3565: - [~junrao] [~ijuma] I tried a few more things in

dev@kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247174#comment-15247174 ] Guozhang Wang commented on KAFKA-3046: -- [~vesense] I'm currently working on KAFKA-349

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

See Changes: [junrao] KAFKA-3582; Remove references to Copcyat from Kafka Connect property -- [...truncated 3825 lines...] org.apache.kafka.common.config.ConfigDefTest > testInvalidDefaultString

[jira] [Assigned] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3117: -- Assignee: Jason Gustafson (was: Neha Narkhede) > Fail test at: PlaintextConsumerTest.

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

See Changes: [junrao] KAFKA-3582; Remove references to Copcyat from Kafka Connect property -- [...truncated 1561 lines...] kafka.integration.AutoOffsetResetTest > testResetToEarliestWhenOffsetT

Re: [VOTE] KIP-33 - Add a time based log index

Hi Grant, Thanks for the review. Please see the replies inline. On Mon, Apr 18, 2016 at 1:56 PM, Grant Henke wrote: > Thanks for the detailed write up Jiangjie. Overall the proposal looks good > to me. I have a few implementation detail questions that > don't necessarily need to block progress:

[jira] [Commented] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246979#comment-15246979 ] Guozhang Wang commented on KAFKA-3564: -- [~mdcoon] In your case you should consider us

[jira] [Commented] (KAFKA-3582) remove references to Copcyat from connect property files

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

[GitHub] kafka pull request: KAFKA-3582: Remove references to Copcyat from ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1236 --- 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] [Updated] (KAFKA-3582) remove references to Copcyat from connect property files

[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3582: --- Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available) Issue res

Re: [VOTE] KIP-33 - Add a time based log index

Thanks for the comments Ismael. Please see the replies inline. On Mon, Apr 18, 2016 at 6:50 AM, Ismael Juma wrote: > Hi Jiangjie, > > Thanks for the KIP, it's a nice improvement. Since it seems like we have > been using the voting thread for discussion, I'll do the same. > > A few minor comments

[jira] [Updated] (KAFKA-3582) remove references to Copcyat from connect property files

[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3582: -- Status: Patch Available (was: In Progress) > remove references to Copcyat from connect property files >

[jira] [Commented] (KAFKA-3582) remove references to Copcyat from connect property files

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

[GitHub] kafka pull request: KAFKA-3582: Remove references to Copcyat from ...

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1236 KAFKA-3582: Remove references to Copcyat from Kafka Connect property files @junrao You can merge this pull request into a Git repository by running: $ git pull https://github.com/Ishiihara

[jira] [Work started] (KAFKA-3582) remove references to Copcyat from connect property files

[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3582 started by Liquan Pei. - > remove references to Copcyat from connect property files > --

[jira] [Assigned] (KAFKA-3582) remove references to Copcyat from connect property files

[ https://issues.apache.org/jira/browse/KAFKA-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3582: - Assignee: Liquan Pei > remove references to Copcyat from connect property files > ---

[jira] [Assigned] (KAFKA-3583) Docs on pause/resume/restart APIs.

[ https://issues.apache.org/jira/browse/KAFKA-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3583: -- Assignee: Jason Gustafson (was: Ewen Cheslack-Postava) > Docs on pause/resume/restart

[jira] [Created] (KAFKA-3583) Docs on pause/resume/restart APIs.

Liquan Pei created KAFKA-3583: - Summary: Docs on pause/resume/restart APIs. Key: KAFKA-3583 URL: https://issues.apache.org/jira/browse/KAFKA-3583 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-3582) remove references to Copcyat from connect property files

Jun Rao created KAFKA-3582: -- Summary: remove references to Copcyat from connect property files Key: KAFKA-3582 URL: https://issues.apache.org/jira/browse/KAFKA-3582 Project: Kafka Issue Type: Improv

[jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3186: -- Fix Version/s: (was: 0.10.1.0) 0.10.0.0 > KIP-50: Move Authorizer and rel

[jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3186: -- Description: [KIP-50|https://cwiki.apache.org/confluence/display/KAFKA/KIP-50+-+Move+Authorizer+

[jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3186: -- Summary: KIP-50: Move Authorizer and related classes to separate package. (was: Kafka authorize

[jira] [Created] (KAFKA-3581) Use timeout when joining threads in system test services

Jason Gustafson created KAFKA-3581: -- Summary: Use timeout when joining threads in system test services Key: KAFKA-3581 URL: https://issues.apache.org/jira/browse/KAFKA-3581 Project: Kafka Is

[jira] [Created] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

Jun Rao created KAFKA-3580: -- Summary: improve error logging in ReplicaFetchThread with oversized message Key: KAFKA-3580 URL: https://issues.apache.org/jira/browse/KAFKA-3580 Project: Kafka Issue T

[jira] [Created] (KAFKA-3579) TopicCommand references outdated consumer property fetch.message.max.bytes

Jun Rao created KAFKA-3579: -- Summary: TopicCommand references outdated consumer property fetch.message.max.bytes Key: KAFKA-3579 URL: https://issues.apache.org/jira/browse/KAFKA-3579 Project: Kafka

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246765#comment-15246765 ] Ismael Juma commented on KAFKA-3565: Interesting about the tuning that may be required

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

See

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

See Changes: [me] KAFKA-3558; Add compression_type parameter to benchmarks in -- [...truncated 4329 lines...] kafka.admin.AdminRackAwareTest > testAssignmentWith2ReplicasRackAwareWith6Partition

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

See Changes: [me] KAFKA-3529: Fix transient failure in testCommitAsync -- [...truncated 5281 lines...] org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameTopic PASSED

[jira] [Updated] (KAFKA-3558) Add compression_type parameter to benchmarks in benchmark_test.py

[ https://issues.apache.org/jira/browse/KAFKA-3558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3558: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was:

[jira] [Commented] (KAFKA-3558) Add compression_type parameter to benchmarks in benchmark_test.py

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

[GitHub] kafka pull request: KAFKA-3558; Add compression_type parameter to ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1225 --- 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] [Comment Edited] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246565#comment-15246565 ] Jiangjie Qin edited comment on KAFKA-3565 at 4/18/16 9:22 PM: --

[jira] [Comment Edited] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246565#comment-15246565 ] Jiangjie Qin edited comment on KAFKA-3565 at 4/18/16 9:21 PM: --

[jira] [Comment Edited] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246565#comment-15246565 ] Jiangjie Qin edited comment on KAFKA-3565 at 4/18/16 9:20 PM: --

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246565#comment-15246565 ] Jiangjie Qin commented on KAFKA-3565: - [~ijuma] I see. So we do know that the throughp

[DISCUSS] KIP-56 Allow cross origin HTTP requests on all HTTP methods

Hi I would like to start a quick discussion on KIP-56 https://cwiki.apache.org/confluence/display/KAFKA/KIP-56%3A+Allow+cross+origin+HTTP+requests+on+all+HTTP+methods This proposal is to allow cross origin HTTP requests on all HTTP methods. Thanks, Liquan -- Liquan Pei Software Engineer, Confl

[jira] [Updated] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kim Christensen updated KAFKA-3564: --- Status: Patch Available (was: In Progress) > Count metric always increments by 1.0 >

[jira] [Assigned] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kim Christensen reassigned KAFKA-3564: -- Assignee: Kim Christensen > Count metric always increments by 1.0 > ---

[jira] [Work started] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3564 started by Kim Christensen. -- > Count metric always increments by 1.0 > ---

[jira] [Commented] (KAFKA-3564) Count metric always increments by 1.0

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

[GitHub] kafka pull request: KAFKA-3564: Count metric always increments by ...

GitHub user kichristensen opened a pull request: https://github.com/apache/kafka/pull/1235 KAFKA-3564: Count metric always increments by 1.0 Increment the counter by the value passed into the function You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-3563) Maintain MessageAndMetadata constructor compatibility

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

[jira] [Updated] (KAFKA-3563) Maintain MessageAndMetadata constructor compatibility

[ https://issues.apache.org/jira/browse/KAFKA-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3563: - Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 0.10

[GitHub] kafka pull request: KAFKA-3563: Maintain MessageAndMetadata constr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1226 --- 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] [Assigned] (KAFKA-3578) Allow cross origin HTTP requests on all HTTP methods

[ https://issues.apache.org/jira/browse/KAFKA-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3578: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Allow cross origin HTTP requests on all HTTP

[jira] [Created] (KAFKA-3578) Allow cross origin HTTP requests on all HTTP methods

Liquan Pei created KAFKA-3578: - Summary: Allow cross origin HTTP requests on all HTTP methods Key: KAFKA-3578 URL: https://issues.apache.org/jira/browse/KAFKA-3578 Project: Kafka Issue Type: Impr

Re: [VOTE] KIP-33 - Add a time based log index

Thanks for the detailed write up Jiangjie. Overall the proposal looks good to me. I have a few implementation detail questions that don't necessarily need to block progress: When searching by timestamp, broker will start from the earliest log > segment and check the last time index entry. If the t

[jira] [Created] (KAFKA-3577) Partial cluster breakdown

Kim Christensen created KAFKA-3577: -- Summary: Partial cluster breakdown Key: KAFKA-3577 URL: https://issues.apache.org/jira/browse/KAFKA-3577 Project: Kafka Issue Type: Bug Affects Versi

[jira] [Comment Edited] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246508#comment-15246508 ] Jun Rao edited comment on KAFKA-3042 at 4/18/16 8:53 PM: - [~fpj],

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246508#comment-15246508 ] Jun Rao commented on KAFKA-3042: [~fpj], yes, I was confused by that initially too. The fo

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246460#comment-15246460 ] Jun Rao commented on KAFKA-3565: [~becket_qin], in the benchmark result that Ismael posted

[GitHub] kafka pull request: KAFKA-3529: fix transient failure in testCommi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1234 --- 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] [Updated] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3529: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was:

[jira] [Commented] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

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

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

See

Jenkins build is back to normal : kafka-trunk-jdk8 #531

See

[jira] [Updated] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3576: --- Fix Version/s: 0.10.1.0 > Unify KStream and KTable API > > >

[jira] [Commented] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

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

[jira] [Updated] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3529: --- Status: Patch Available (was: Open) > Transient kafka.api.PlaintextConsumerTest.testAsyncComm

[GitHub] kafka pull request: KAFKA-3529: fix transient failure in testCommi...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1234 KAFKA-3529: fix transient failure in testCommitAsync You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3529 Alternatively

[jira] [Created] (KAFKA-3576) Unify KStream and KTable API

Matthias J. Sax created KAFKA-3576: -- Summary: Unify KStream and KTable API Key: KAFKA-3576 URL: https://issues.apache.org/jira/browse/KAFKA-3576 Project: Kafka Issue Type: Sub-task

[jira] [Work started] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3429 started by Matthias J. Sax. -- > Remove Serdes needed for repartitioning in KTable stateful operations > ---

[jira] [Commented] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246262#comment-15246262 ] Jason Gustafson commented on KAFKA-3529: [~ijuma] [~guozhang] Since we call poll(0

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

Unifying the two discussion threads on this KIP. Here is the response from Jitendra "The need for a large number of clients that are running all over the cluster that authenticate with Kafka brokers, is very similar to the Hadoop use case of large number of tasks running across the cluster that n

[jira] [Assigned] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3529: -- Assignee: Jason Gustafson > Transient kafka.api.PlaintextConsumerTest.testAsyncCommit f

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

Sending it again on the existing thread. The need for a large number of clients that are running all over the cluster that authenticate with Kafka brokers, is very similar to the Hadoop use case of large number of tasks running across the cluster that need authentication to Hdfs Namenode. Th

[jira] [Commented] (KAFKA-3506) Kafka Connect Task Restart API

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

[GitHub] kafka pull request: KAFKA-3506: Kafka Connect restart APIs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1189 --- 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] [Updated] (KAFKA-3506) Kafka Connect Task Restart API

[ https://issues.apache.org/jira/browse/KAFKA-3506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3506: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was:

Re: kafka streaming: passing config string to Processor

Hello, thanks, I plan to carry on some tests. And I will support sources in actual state - https://github.com/rssdev10/streaming-benchmarks/tree/master/kafka-benchmarks. As the Kafka 10 is absent in apache mirrors and in maven central it is impossible to use default yahoo's start script. Workaro

Re: [DISCUSS] KIP-54 Sticky Partition Assignment Strategy

HI Jason, Thanks for your feedback. I believe your suggestion on how to take advantage of this assignor is valid. We can leverage onPartitionsRevoked() and onPartitionsAssigned() callbacks and do a comparison of assigned partitions before and after the re-balance and do the cleanup only if the

Re: Reg: Issue with Kafka Kerberos (Kafka Version 0.9.0.1)

Hi Harsha, It worked. I need to configure property super.users=User:kafka. (U should be capital in user, because of this issue, I have got the authentication error). Regards, Bharat On Sat, Apr 16, 2016 at 9:21 AM, Harsha wrote: > Bharat, > Did you add super.users=user:kafka to

[jira] [Commented] (KAFKA-3492) support quota based on authenticated user name

[ https://issues.apache.org/jira/browse/KAFKA-3492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245888#comment-15245888 ] Rajini Sivaram commented on KAFKA-3492: --- [~junrao] [~aauradkar] [~thesquelched] I ha

[jira] [Updated] (KAFKA-3492) support quota based on authenticated user name

[ https://issues.apache.org/jira/browse/KAFKA-3492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3492: -- Description: Currently, quota is based on the client.id set in the client configuration, which

[DISCUSS] KIP-55: Secure quotas for authenticated users

Hi All, I have just created KIP-55 to support quotas based on authenticated user principals. https://cwiki.apache.org/confluence/display/KAFKA/KIP-55%3A+Secure+Quotas+for+Authenticated+Users Comments and feedback are appreciated. Thank you... Regards, Rajini

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245725#comment-15245725 ] Flavio Junqueira commented on KAFKA-3042: - I checked the broker change listener ou

Re: [VOTE] KIP-33 - Add a time based log index

Hi Jiangjie, Thanks for the KIP, it's a nice improvement. Since it seems like we have been using the voting thread for discussion, I'll do the same. A few minor comments/questions: 1. The proposed name for the time index file `SegmentBaseOffset.timeindex`. Would `SegmentBaseOffset.time-index` be

[jira] [Updated] (KAFKA-2955) Add Prompt to kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-2955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2955: --- Assignee: Manikumar Reddy (was: Jun Rao) Fix Version/s: 0.10.0.0 Status: P

[jira] [Commented] (KAFKA-2955) Add Prompt to kafka-console-producer

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

[GitHub] kafka pull request: KAFKA-2955; Add a simple ">" prompt to console...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1233 KAFKA-2955; Add a simple ">" prompt to console producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka KAFKA-2955 Alternativel

Re: KTable.count(...)

Hi Liquan, Thanks for getting back to me and pointing me to the confluent doco. Based on what i read and my own assumptions, i'd expect the data consumed from the output topic to be: A:1 A:2 A:3 A:4 A:5 What am i missing? Thanks, Damian On Sun, 17 Apr 2016 at 19:20 Liquan Pei wrote: > Hi Dam

[jira] [Commented] (KAFKA-3391) Kafka to ZK timeout

[ https://issues.apache.org/jira/browse/KAFKA-3391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245402#comment-15245402 ] Manikumar Reddy commented on KAFKA-3391: increasing ZK timeout may help. Kafka us

[jira] [Resolved] (KAFKA-2416) misleading kafka-console-consumer.sh --property option

[ https://issues.apache.org/jira/browse/KAFKA-2416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2416. Resolution: Fixed Assignee: (was: Sreepathi Prasanna) This got fixed in KAFKA-3256

[jira] [Commented] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245384#comment-15245384 ] Matthias J. Sax commented on KAFKA-3429: Ok. This does not contradict my thoughts.

[jira] [Resolved] (KAFKA-2157) kafka-console-consumer.sh: Mismatch in CLI "usage" docs vs. Scala Option parsing

[ https://issues.apache.org/jira/browse/KAFKA-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2157. Resolution: Fixed Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 This is

[jira] [Resolved] (KAFKA-361) Add ability to get offsets from ZK-based consumer

[ https://issues.apache.org/jira/browse/KAFKA-361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-361. --- Resolution: Fixed > Add ability to get offsets from ZK-based consumer > ---

[jira] [Resolved] (KAFKA-364) Consumer re-design

[ https://issues.apache.org/jira/browse/KAFKA-364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-364. --- Resolution: Fixed > Consumer re-design > -- > > Key: KAFKA-364

[jira] [Resolved] (KAFKA-360) Add ability to disable rebalancing in ZooKeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-360. --- Resolution: Fixed > Add ability to disable rebalancing in ZooKeeper consumer >

[jira] [Resolved] (KAFKA-390) Implement the rebalancing protocol between co-ordinator and consumer

[ https://issues.apache.org/jira/browse/KAFKA-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-390. --- Resolution: Duplicate > Implement the rebalancing protocol between co-ordinator and consumer >

[jira] [Resolved] (KAFKA-389) Add a consumer client that connects to the co-ordinator for rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-389. --- Resolution: Duplicate > Add a consumer client that connects to the co-ordinator for rebalancing

[jira] [Resolved] (KAFKA-387) Add a centralized co-ordinator for consumer rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-387. --- Resolution: Duplicate > Add a centralized co-ordinator for consumer rebalancing > -

[jira] [Created] (KAFKA-3575) Use console consumer access topic that does not exist, can not use "Control + C" to exit process

NieWang created KAFKA-3575: -- Summary: Use console consumer access topic that does not exist, can not use "Control + C" to exit process Key: KAFKA-3575 URL: https://issues.apache.org/jira/browse/KAFKA-3575 Pr

[jira] [Commented] (KAFKA-3517) Document configuration of SASL/PLAIN and multiple mechanisms

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

[GitHub] kafka pull request: KAFKA-3517: Add documentation for SASL/PLAIN

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1232 KAFKA-3517: Add documentation for SASL/PLAIN Documentation corresponding to KIP-43 - SASL/PLAIN and multiple mechanism support. You can merge this pull request into a Git repository by runnin

  1   2   >