[jira] [Commented] (KAFKA-3267) Describe/Alter Configs protocol, server and client (KIP-133)

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

[jira] [Updated] (KAFKA-3267) Describe/Alter Configs protocol, server and client (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3267: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request #3076: KAFKA-3267: Describe and Alter Configs Admin APIs ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3076 --- 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

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

See

[jira] [Created] (KAFKA-5277) Sticky Assignor should not cache the calculated assignment (KIP-54 follow-up)

Vahid Hashemian created KAFKA-5277: -- Summary: Sticky Assignor should not cache the calculated assignment (KIP-54 follow-up) Key: KAFKA-5277 URL: https://issues.apache.org/jira/browse/KAFKA-5277

[GitHub] kafka pull request #1020: KAFKA-2273: Sticky partition assignment strategy (...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1020 --- 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

[jira] [Commented] (KAFKA-2273) KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

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

[jira] [Updated] (KAFKA-2273) KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2273: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull

[jira] [Assigned] (KAFKA-3995) Split the ProducerBatch and resend when received RecordTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3995: -- Assignee: Jiangjie Qin (was: Mayuresh Gharat) > Split the ProducerBatch and resend when

[jira] [Updated] (KAFKA-3995) Split the ProducerBatch and resend when received RecordTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3995: --- Status: Patch Available (was: Reopened) > Split the ProducerBatch and resend when received

[jira] [Updated] (KAFKA-3266) Implement KIP-140 RPCs and APIs for creating, altering, and listing ACLs

[ https://issues.apache.org/jira/browse/KAFKA-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3266: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Implement KIP-140 RPCs and APIs

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:41 AM: - I think if we do

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:41 AM: - I think if we do

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015110#comment-16015110 ] james chien commented on KAFKA-4830: I think if we do that then we will introduce a new API called

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

See Changes: [wangguoz] KAFKA-5231: Bump up producer epoch when sending abort txn markers on -- [...truncated 1.36 MB...]

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:40 AM: - I think if we do

[jira] [Commented] (KAFKA-3266) Implement KIP-140 RPCs and APIs for creating, altering, and listing ACLs

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

[GitHub] kafka pull request #2941: KAFKA-3266: Implement KIP-140 RPCs and APIs for cr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2941 --- 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

[jira] [Assigned] (KAFKA-5275) Review and potentially tweak AdminClient API for the initial release (KIP-117)

[ https://issues.apache.org/jira/browse/KAFKA-5275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5275: -- Assignee: Ismael Juma > Review and potentially tweak AdminClient API for the initial release

[jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5276: --- Summary: Support derived and prefixed configs in DescribeConfigs (KIP-133) (was: Support derived and

[jira] [Commented] (KAFKA-5275) Review and potentially tweak AdminClient API for the initial release (KIP-117)

[ https://issues.apache.org/jira/browse/KAFKA-5275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015081#comment-16015081 ] Ismael Juma commented on KAFKA-5275: Because the ACLs and Configs PRs were developed in parallel,

[GitHub] kafka pull request #3074: KAFKA-5036: hold onto the leader lock in Partition...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3074 --- 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

[jira] [Resolved] (KAFKA-5036) Followups from KIP-101

[ https://issues.apache.org/jira/browse/KAFKA-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5036. Resolution: Fixed Issue resolved by pull request 3074 [https://github.com/apache/kafka/pull/3074] >

[jira] [Assigned] (KAFKA-5036) Followups from KIP-101

[ https://issues.apache.org/jira/browse/KAFKA-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-5036: -- Assignee: Ben Stopford (was: Jun Rao) > Followups from KIP-101 > -- > >

[jira] [Commented] (KAFKA-5036) Followups from KIP-101

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

[jira] [Created] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs

Ismael Juma created KAFKA-5276: -- Summary: Support derived and prefixed configs in DescribeConfigs Key: KAFKA-5276 URL: https://issues.apache.org/jira/browse/KAFKA-5276 Project: Kafka Issue

[jira] [Created] (KAFKA-5275) Review and potentially tweak AdminClient API for the initial release (KIP-117)

Ismael Juma created KAFKA-5275: -- Summary: Review and potentially tweak AdminClient API for the initial release (KIP-117) Key: KAFKA-5275 URL: https://issues.apache.org/jira/browse/KAFKA-5275 Project:

[jira] [Updated] (KAFKA-5274) Review and improve AdminClient Javadoc for the first release (KIP-117)

[ https://issues.apache.org/jira/browse/KAFKA-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5274: --- Summary: Review and improve AdminClient Javadoc for the first release (KIP-117) (was: Review and

[jira] [Commented] (KAFKA-1955) Explore disk-based buffering in new Kafka Producer

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

[jira] [Created] (KAFKA-5274) Review and improve AdminClient Javadoc for the first release

Ismael Juma created KAFKA-5274: -- Summary: Review and improve AdminClient Javadoc for the first release Key: KAFKA-5274 URL: https://issues.apache.org/jira/browse/KAFKA-5274 Project: Kafka

[jira] [Updated] (KAFKA-5274) Review and improve AdminClient Javadoc for the first release (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5274: --- Summary: Review and improve AdminClient Javadoc for the first release (KIP-133) (was: Review and

[GitHub] kafka pull request #3083: KAFKA-1955: [WIP] Disk based buffer in Producer

GitHub user blbradley opened a pull request: https://github.com/apache/kafka/pull/3083 KAFKA-1955: [WIP] Disk based buffer in Producer Based on patch from @jkreps in [this JIRA ticket](https://issues.apache.org/jira/browse/KAFKA-1955). - [ ] Get some unit tests that would

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015043#comment-16015043 ] james chien commented on KAFKA-4830: great, I will work on this :) > Augment KStream.print() to allow

[jira] [Assigned] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-4830: -- Assignee: james chien > Augment KStream.print() to allow users pass in extra parameters in the

[jira] [Commented] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

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

[jira] [Commented] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

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

[GitHub] kafka pull request #3082: KAFKA-5231: Protect txn metadata map with read-wri...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3082 KAFKA-5231: Protect txn metadata map with read-write lock You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[GitHub] kafka pull request #3066: KAFKA-5231: Bump up producer epoch when sending ab...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3066 --- 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

[jira] [Resolved] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

[ https://issues.apache.org/jira/browse/KAFKA-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5231. -- Resolution: Fixed Issue resolved by pull request 3066

[GitHub] kafka pull request #3081: MINOR: Log transaction metadata state transitions ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3081 MINOR: Log transaction metadata state transitions plus a few cleanups You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Created] (KAFKA-5273) KafkaConsumer.committed() should get latest committed offsets from the server

Apurva Mehta created KAFKA-5273: --- Summary: KafkaConsumer.committed() should get latest committed offsets from the server Key: KAFKA-5273 URL: https://issues.apache.org/jira/browse/KAFKA-5273 Project:

[jira] [Work started] (KAFKA-5272) Improve validation for Describe/Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5272 started by Ismael Juma. -- > Improve validation for Describe/Alter Configs (KIP-133) >

[jira] [Created] (KAFKA-5272) Improve validation for Describe/Alter Configs (KIP-133)

Ismael Juma created KAFKA-5272: -- Summary: Improve validation for Describe/Alter Configs (KIP-133) Key: KAFKA-5272 URL: https://issues.apache.org/jira/browse/KAFKA-5272 Project: Kafka Issue

[jira] [Updated] (KAFKA-3267) Describe/Alter Configs protocol, server and client (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3267: --- Summary: Describe/Alter Configs protocol, server and client (KIP-133) (was: Describe/Alter Configs

[jira] [Commented] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014945#comment-16014945 ] Stephane Maarek commented on KAFKA-5261: this and possibly {code} private def aclMatch(session:

[jira] [Assigned] (KAFKA-4278) Undocumented REST resources

[ https://issues.apache.org/jira/browse/KAFKA-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-4278: - Assignee: (was: Bharat Viswanadham) > Undocumented REST resources >

[jira] [Commented] (KAFKA-5188) Add Integration tests for transactional producer

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

[GitHub] kafka pull request #2994: KAFKA-5188: Integration tests for transactions

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2994 --- 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

[jira] [Resolved] (KAFKA-5188) Add Integration tests for transactional producer

[ https://issues.apache.org/jira/browse/KAFKA-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5188. Resolution: Fixed Issue resolved by pull request 2994

[jira] [Assigned] (KAFKA-5268) TransactionsBounceTest occasionally sees INVALID_TXN_STATE errors

[ https://issues.apache.org/jira/browse/KAFKA-5268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-5268: -- Assignee: Jason Gustafson > TransactionsBounceTest occasionally sees INVALID_TXN_STATE

[jira] [Assigned] (KAFKA-5269) TransactionBounceTest occasionally fails due to partition errors

[ https://issues.apache.org/jira/browse/KAFKA-5269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5269: --- Assignee: Apurva Mehta > TransactionBounceTest occasionally fails due to partition errors >

[jira] [Resolved] (KAFKA-5271) Producer only needs to send AddOffsetsToTxn one time for each group

[ https://issues.apache.org/jira/browse/KAFKA-5271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5271. Resolution: Duplicate Sorry for the noise. Created this just as Apurva was creating a

[jira] [Created] (KAFKA-5271) Producer only needs to send AddOffsetsToTxn one time for each group

Jason Gustafson created KAFKA-5271: -- Summary: Producer only needs to send AddOffsetsToTxn one time for each group Key: KAFKA-5271 URL: https://issues.apache.org/jira/browse/KAFKA-5271 Project: Kafka

[jira] [Created] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction

Apurva Mehta created KAFKA-5270: --- Summary: TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction Key: KAFKA-5270 URL: https://issues.apache.org/jira/browse/KAFKA-5270

[jira] [Commented] (KAFKA-5269) TransactionBounceTest occasionally fails due to partition errors

[ https://issues.apache.org/jira/browse/KAFKA-5269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014864#comment-16014864 ] Apurva Mehta commented on KAFKA-5269: - A relevant stack trace: {noformat} [2017-05-17 15:15:38,145]

[jira] [Updated] (KAFKA-5269) TransactionBounceTest occasionally fails due to partition errors

[ https://issues.apache.org/jira/browse/KAFKA-5269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5269: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > TransactionBounceTest occasionally

[jira] [Created] (KAFKA-5269) TransactionBounceTest occasionally fails due to partition errors

Apurva Mehta created KAFKA-5269: --- Summary: TransactionBounceTest occasionally fails due to partition errors Key: KAFKA-5269 URL: https://issues.apache.org/jira/browse/KAFKA-5269 Project: Kafka

[jira] [Updated] (KAFKA-5268) TransactionsBounceTest occasionally sees INVALID_TXN_STATE errors

[ https://issues.apache.org/jira/browse/KAFKA-5268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5268: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > TransactionsBounceTest occasionally

[jira] [Created] (KAFKA-5268) TransactionsBounceTest occasionally sees INVALID_TXN_STATE errors

Apurva Mehta created KAFKA-5268: --- Summary: TransactionsBounceTest occasionally sees INVALID_TXN_STATE errors Key: KAFKA-5268 URL: https://issues.apache.org/jira/browse/KAFKA-5268 Project: Kafka

[jira] [Created] (KAFKA-5267) Simplify KStreamPrint using RichFunctions

Matthias J. Sax created KAFKA-5267: -- Summary: Simplify KStreamPrint using RichFunctions Key: KAFKA-5267 URL: https://issues.apache.org/jira/browse/KAFKA-5267 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

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

[GitHub] kafka pull request #2624: KAFKA-4743: Add Reset Consumer Group Offsets tooli...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2624 --- 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

[jira] [Updated] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4743: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull

[jira] [Created] (KAFKA-5266) Follow-up improvements for consumer offset reset tool (KIP-122)

Jason Gustafson created KAFKA-5266: -- Summary: Follow-up improvements for consumer offset reset tool (KIP-122) Key: KAFKA-5266 URL: https://issues.apache.org/jira/browse/KAFKA-5266 Project: Kafka

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014715#comment-16014715 ] Matthias J. Sax commented on KAFKA-4830: [~james.c] KAFKA-4772 got merged. So feel free to work on

[jira] [Updated] (KAFKA-5255) Auto generate request/response classes

[ https://issues.apache.org/jira/browse/KAFKA-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5255: --- Fix Version/s: 0.11.1.0 > Auto generate request/response classes >

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

Hi, When I was trying to find more info, there is already a proposed KIP for this https://cwiki.apache.org/confluence/display/KAFKA/KIP-14+-+Tools+Standardization Thanks, Bharat On Wed, May 17, 2017 at 12:38 PM, BigData dev wrote: > Hi Ewen, Matthias, > For common

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

Hi Ewen, Matthias, For common configuration across all the tools, I will work on that as part of other KIP by looking into all Kafka tools. Thanks, Bharat On Wed, May 17, 2017 at 9:40 AM, Matthias J. Sax wrote: > +1 > > I also second Ewen comment -- standardizing the

[jira] [Work started] (KAFKA-4278) Undocumented REST resources

[ https://issues.apache.org/jira/browse/KAFKA-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4278 started by Bharat Viswanadham. - > Undocumented REST resources > --- > >

[jira] [Assigned] (KAFKA-4278) Undocumented REST resources

[ https://issues.apache.org/jira/browse/KAFKA-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-4278: - Assignee: Bharat Viswanadham > Undocumented REST resources >

[jira] [Updated] (KAFKA-3267) Describe/Alter Configs protocol and server side implementation (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3267: --- Status: Patch Available (was: In Progress) > Describe/Alter Configs protocol and server side

[jira] [Commented] (KAFKA-1955) Explore disk-based buffering in new Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-1955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014550#comment-16014550 ] Brandon Bradley commented on KAFKA-1955: The rebased patch applies cleanly to 68ad80f8. I'm trying

[jira] [Updated] (KAFKA-5265) Move ACLs, Config, NodeVersions classes into org.apache.kafka.common

[ https://issues.apache.org/jira/browse/KAFKA-5265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5265: --- Fix Version/s: 0.11.0.0 > Move ACLs, Config, NodeVersions classes into

[jira] [Updated] (KAFKA-5265) Move ACLs, Config, NodeVersions classes into org.apache.kafka.common

[ https://issues.apache.org/jira/browse/KAFKA-5265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5265: --- Affects Version/s: 0.11.0.0 > Move ACLs, Config, NodeVersions classes into

[jira] [Created] (KAFKA-5265) Move ACLs, Config, NodeVersions classes into org.apache.kafka.common

Colin P. McCabe created KAFKA-5265: -- Summary: Move ACLs, Config, NodeVersions classes into org.apache.kafka.common Key: KAFKA-5265 URL: https://issues.apache.org/jira/browse/KAFKA-5265 Project:

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[GitHub] kafka pull request #2955: KAFKA-4772: Exploit #peek to implement #print() an...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2955 --- 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

[jira] [Resolved] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[jira] [Assigned] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5226: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > NullPointerException (NPE) in

[jira] [Work started] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4171 started by Bharat Viswanadham. - > Kafka-connect prints outs keystone and truststore password in log2 >

[jira] [Created] (KAFKA-5264) kafka.api.SslProducerSendTest.testSendToPartition transient failure

Xavier Léauté created KAFKA-5264: Summary: kafka.api.SslProducerSendTest.testSendToPartition transient failure Key: KAFKA-5264 URL: https://issues.apache.org/jira/browse/KAFKA-5264 Project: Kafka

[jira] [Commented] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014528#comment-16014528 ] Bharat Viswanadham commented on KAFKA-4171: --- Hi Ewen, Please let me know any more work is

[jira] [Commented] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014526#comment-16014526 ] Bharat Viswanadham commented on KAFKA-4171: --- Hi, I think this issue got resolved, I think this

[jira] [Assigned] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-4171: - Assignee: Bharat Viswanadham > Kafka-connect prints outs keystone and truststore

[jira] [Commented] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014491#comment-16014491 ] Alexis Lesieur commented on KAFKA-1313: --- I feel like an "easy" fix for this would at least be enable

[jira] [Updated] (KAFKA-5258) move all partition and replica state transition rules into their states

[ https://issues.apache.org/jira/browse/KAFKA-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5258: Description: Today the PartitionStateMachine and ReplicaStateMachine defines and asserts the valid

[jira] [Updated] (KAFKA-5258) move all partition and replica state transition rules into their states

[ https://issues.apache.org/jira/browse/KAFKA-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5258: Description: Today the PartitionStateMachine and ReplicaStateMachine defines and asserts the valid

[jira] [Updated] (KAFKA-5258) move all partition and replica state transition rules into their states

[ https://issues.apache.org/jira/browse/KAFKA-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5258: Summary: move all partition and replica state transition rules into their states (was: move all

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

+1 I also second Ewen comment -- standardizing the common supported parameters over all tools would be great! -Matthias On 5/17/17 12:57 AM, Damian Guy wrote: > +1 > > On Wed, 17 May 2017 at 05:40 Ewen Cheslack-Postava > wrote: > >> +1 (binding) >> >> I mentioned this in

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014328#comment-16014328 ] Matthias J. Sax commented on KAFKA-5245: You can just assign the JIRA to yourself and get started

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

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

[jira] [Comment Edited] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014310#comment-16014310 ] anugrah edited comment on KAFKA-5245 at 5/17/17 4:09 PM: - hey, i would like to

[GitHub] kafka pull request #3080: KAFKA-4222: QueryableIntegrationTest.queryOnRebala...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3080 KAFKA-4222: QueryableIntegrationTest.queryOnRebalance transient failure Don't produce messages on a separate thread continuosly. Just produce one of each value and stop. Close the producer once

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014310#comment-16014310 ] anugrah commented on KAFKA-5245: hey, i would like to work on this. Any pointers as to how am i supposed

[jira] [Updated] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment when network connection is lost

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Smirnov updated KAFKA-5263: -- Attachment: cpu_consuming_profile.csv Captured profile > kakfa-clients consume 100%

[jira] [Updated] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment when network connection is lost

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Smirnov updated KAFKA-5263: -- Attachment: cpu_consuming.log Sample application output > kakfa-clients consume 100%

[jira] [Updated] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment when network connection is lost

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Smirnov updated KAFKA-5263: -- Summary: kakfa-clients consume 100% CPU with manual partition assignment when network

[jira] [Comment Edited] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014226#comment-16014226 ] Konstantin Smirnov edited comment on KAFKA-5263 at 5/17/17 3:36 PM:

[jira] [Commented] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014226#comment-16014226 ] Konstantin Smirnov commented on KAFKA-5263: --- Sample code leading to the trouble: {code} public

[jira] [Updated] (KAFKA-5263) kakfa-clients consume 100% CPU with manual partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Smirnov updated KAFKA-5263: -- Affects Version/s: 0.10.1.0 0.10.1.1 Description:

  1   2   >