[jira] [Created] (KAFKA-5261) Performance improvement of SimpleAclAuthoriser

Stephane Maarek created KAFKA-5261: -- Summary: Performance improvement of SimpleAclAuthoriser Key: KAFKA-5261 URL: https://issues.apache.org/jira/browse/KAFKA-5261 Project: Kafka Issue Type:

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

[ https://issues.apache.org/jira/browse/KAFKA-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5261: --- Summary: Performance improvement of SimpleAclAuthorizer (was: Performance improvement of Simp

[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&focusedCommentId=16013665#comment-16013665 ] Onur Karaman commented on KAFKA-5261: - Would one alternative be to just make a CachedA

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

See Changes: [jason] KAFKA-4714; Flatten and Cast single message transforms (KIP-66) -- [...truncated 1.68 MB...] org.apache.kafka.streams.processor.TopologyBuilderTest >

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

+1 On Wed, 17 May 2017 at 05:40 Ewen Cheslack-Postava wrote: > +1 (binding) > > I mentioned this in the PR that triggered this: > > > KIP is accurate, though this is one of those things that we should > probably get a KIP for a standard set of config options across all tools so > additions like

[jira] [Commented] (KAFKA-5048) kafka brokers hang when one of broker node killed in the cluster and remaining broker nodes are not consuming the data.

[ https://issues.apache.org/jira/browse/KAFKA-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013852#comment-16013852 ] Srinivas Yarra commented on KAFKA-5048: --- replication.factor=2 > kafka brokers hang

[GitHub] kafka pull request #3078: MINOR: Use exceptions from clients jar if possible

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3078 MINOR: Use exceptions from clients jar if possible * Avoid `import kafka.common._` * Delete now unused kafka.common.InvalidOffsetException * Change kafka.common.KafkaException to inherit from

[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&focusedCommentId=16013872#comment-16013872 ] Ismael Juma commented on KAFKA-5261: Is this a bottleneck? We have an in-memory cache:

[GitHub] kafka pull request #2393: MINOR: Use new-consumer config in MirrorMaker doc

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

[GitHub] kafka pull request #3070: AdminClient: add some more APIs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3070 --- 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-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhimanyu Nagrath updated KAFKA-5221: - Priority: Critical (was: Major) > Kafka Consumer Attached to partition but not consuming

[jira] [Updated] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhimanyu Nagrath updated KAFKA-5222: - Priority: Critical (was: Minor) > Kafka Connection error in contoller.logs >

[jira] [Updated] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhimanyu Nagrath updated KAFKA-5222: - Priority: Major (was: Critical) > Kafka Connection error in contoller.logs >

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

See

[GitHub] kafka pull request #3079: MINOR: Removed the redundant code snippets.

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/3079 MINOR: Removed the redundant code snippets. - Removed the unwanted null check in the hashCode and equals method. You can merge this pull request into a Git repository by running: $ git pull ht

[jira] [Commented] (KAFKA-1995) JMS to Kafka: Inbuilt JMSAdaptor/JMSProxy/JMSBridge (Client can speak JMS but hit Kafka)

[ https://issues.apache.org/jira/browse/KAFKA-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013975#comment-16013975 ] Yaniv Kunda commented on KAFKA-1995: You can check out Confluent's JMS Client for Kafk

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

See

[jira] [Updated] (KAFKA-5250) handleFetchRequest should do down conversion after throttling

[ https://issues.apache.org/jira/browse/KAFKA-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5250: --- Priority: Critical (was: Major) > handleFetchRequest should do down conversion after throttling > ---

[GitHub] kafka pull request #3057: KAFKA-5182: Reduce session timeout in request quot...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3057 --- 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-5182) Transient failure: RequestQuotaTest.testResponseThrottleTime

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

[jira] [Resolved] (KAFKA-5182) Transient failure: RequestQuotaTest.testResponseThrottleTime

[ https://issues.apache.org/jira/browse/KAFKA-5182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5182. --- Resolution: Fixed Issue resolved by pull request 3057 [https://github.com/apache/kafka/pull/30

[GitHub] kafka pull request #3043: KAFKA-5232 Fix Log.parseTopicPartitionName to take...

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

[jira] [Commented] (KAFKA-5232) Kafka broker fails to start if a topic containing dot in its name is marked for delete but hasn't been deleted during previous uptime

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

[jira] [Created] (KAFKA-5262) Can't find some consumer group information

miaozhiyong created KAFKA-5262: -- Summary: Can't find some consumer group information Key: KAFKA-5262 URL: https://issues.apache.org/jira/browse/KAFKA-5262 Project: Kafka Issue Type: Bug

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

Konstantin Smirnov created KAFKA-5263: - Summary: kakfa-clients consume 100% CPU with manual partition assignment Key: KAFKA-5263 URL: https://issues.apache.org/jira/browse/KAFKA-5263 Project: Kafk

[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: Notice

[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&focusedCommentId=16014226#comment-16014226 ] Konstantin Smirnov commented on KAFKA-5263: --- Sample code leading to the trouble:

[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&focusedCommentId=16014226#comment-16014226 ] Konstantin Smirnov edited comment on KAFKA-5263 at 5/17/17 3:36 PM:

[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 co

[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% CP

[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% CPU

[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&focusedCommentId=16014310#comment-16014310 ] anugrah commented on KAFKA-5245: hey, i would like to work on this. Any pointers as to how

[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 fin

[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&focusedCommentId=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&focusedCommentId=16014310#comment-16014310 ] anugrah edited comment on KAFKA-5245 at 5/17/17 4:09 PM: - hey, i w

[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&focusedCommentId=16014328#comment-16014328 ] Matthias J. Sax commented on KAFKA-5245: You can just assign the JIRA to yourself

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 the PR that triggere

[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 par

[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] [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&focusedCommentId=16014491#comment-16014491 ] Alexis Lesieur commented on KAFKA-1313: --- I feel like an "easy" fix for this would at

[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-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&focusedCommentId=16014526#comment-16014526 ] Bharat Viswanadham commented on KAFKA-4171: --- Hi, I think this issue got resolved

[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&focusedCommentId=16014528#comment-16014528 ] Bharat Viswanadham commented on KAFKA-4171: --- Hi Ewen, Please let me know any mor

[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] [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] [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 SourceNodeRecordD

[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 [https://gi

[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 enab

[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&focusedCommentId=16014539#comment-16014539 ] ASF GitHub Bot commented on KAFKA-4772: --- Github user asfgit closed the pull request

[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: Kafka

[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 org.apache.kafka.co

[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 org.apache.kafka.common

[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&focusedCommentId=16014550#comment-16014550 ] Brandon Bradley commented on KAFKA-1955: The rebased patch applies cleanly to 68ad

[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 implemen

[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] [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 > --- > >

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 common supported > parame

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 configuration across all the

[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 > ---

[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&focusedCommentId=16014715#comment-16014715 ] Matthias J. Sax commented on KAFKA-4830: [~james.c] KAFKA-4772 got merged. So feel

[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] [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 requ

[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 enab

[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&focusedCommentId=16014804#comment-16014804 ] ASF GitHub Bot commented on KAFKA-4743: --- Github user asfgit closed the pull request

[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: Impro

[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] [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 se

[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-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 fai

[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&focusedCommentId=16014864#comment-16014864 ] Apurva Mehta commented on KAFKA-5269: - A relevant stack trace: {noformat} [2017-05-17

[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] [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] [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 simila

[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] [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] [Updated] (KAFKA-4667) KIP-154: Connect should create internal topics

[ https://issues.apache.org/jira/browse/KAFKA-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-4667: - Reviewer: Ewen Cheslack-Postava Status: Patch Available (was: In Progress) The PR is ready

[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 enab

[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 [https://github.com/apache/kafka/pull/

[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&focusedCommentId=16014929#comment-16014929 ] ASF GitHub Bot commented on KAFKA-5188: --- Github user asfgit closed the pull request

[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-5261) Performance improvement of SimpleAclAuthorizer

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

[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 pr

[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 Type:

[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-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: Ka

[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 minor-a

[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 [https://github.com/apache/kafka/pull/3066

[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 enab

[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&focusedCommentId=16015016#comment-16015016 ] ASF GitHub Bot commented on KAFKA-5231: --- Github user asfgit closed the pull request

[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 K5231-read-wri

[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&focusedCommentId=16015019#comment-16015019 ] ASF GitHub Bot commented on KAFKA-5231: --- GitHub user guozhangwang opened a pull requ

[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-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&focusedCommentId=16015043#comment-16015043 ] james chien commented on KAFKA-4830: great, I will work on this :) > Augment KStream.

[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 c

[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 Issue

[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 impr

[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&focusedCommentId=16015046#comment-16015046 ] ASF GitHub Bot commented on KAFKA-1955: --- GitHub user blbradley opened a pull request

[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 impr

[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: Kaf

  1   2   >