[jira] [Comment Edited] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969831#comment-15969831 ] anugrah edited comment on KAFKA-5049 at 4/15/17 6:52 AM: - Thank yo

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969831#comment-15969831 ] anugrah commented on KAFKA-5049: Thank you [~umesh9...@gmail.com] will do the same > Chro

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969805#comment-15969805 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] you can send a PR and for detai

[jira] [Commented] (KAFKA-4912) Add check for topic name length

[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969786#comment-15969786 ] Soumabrata Chakraborty commented on KAFKA-4912: --- Sounds good. Thanks [~mjsax

Re: [VOTE] 0.10.2.1 RC1

+1 (binding). Verified signatures, ran quickstart and tests. On Fri, Apr 14, 2017 at 3:45 PM Gwen Shapira wrote: > Verified my own signatures, ran quickstart and created few Connectors. > > +1 (binding) > > > On Wed, Apr 12, 2017 at 5:25 PM, Gwen Shapira wrote: > > Hello Kafka users, developers

[jira] [Assigned] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Soumabrata Chakraborty reassigned KAFKA-5072: - Assignee: Soumabrata Chakraborty > Kafka topics should allow custom metad

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969764#comment-15969764 ] Gwen Shapira commented on KAFKA-5075: - Cool. I'll check back on Monday. > The positio

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969730#comment-15969730 ] Jiangjie Qin commented on KAFKA-5075: - [~lindong] is currently working on the patch. H

[jira] [Created] (KAFKA-5076) Remove usage of java.xml.bind.* classes hidden by default in JDK9

Xavier Léauté created KAFKA-5076: Summary: Remove usage of java.xml.bind.* classes hidden by default in JDK9 Key: KAFKA-5076 URL: https://issues.apache.org/jira/browse/KAFKA-5076 Project: Kafka

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969719#comment-15969719 ] Gwen Shapira commented on KAFKA-5075: - I don't mind doing another RC, since I agree da

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969699#comment-15969699 ] Jiangjie Qin commented on KAFKA-5075: - [~gwenshap] I was actually about to reply on th

[jira] [Assigned] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-5075: --- Assignee: Dong Lin > The position in the consumers may be advanced incorrectly when some exce

[jira] [Commented] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969681#comment-15969681 ] Gwen Shapira commented on KAFKA-5075: - I changed the fixVersion since this isn't marke

[jira] [Updated] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-5075: Fix Version/s: (was: 0.10.2.1) 0.11.0.0 > The position in the consumers may b

[jira] [Updated] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[ https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-5075: Affects Version/s: 0.10.2.0 Fix Version/s: 0.10.2.1 Component/s: consumer

[jira] [Created] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

Jiangjie Qin created KAFKA-5075: --- Summary: The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll() Key: KAFKA-5075 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Updated] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4144: --- Labels: api kip (was: api needs-kip) > Allow per stream/table timestamp extractor > -

[jira] [Updated] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4144: --- Description: At the moment the timestamp extractor is configured via a {{StreamConfig}} value

Re: [VOTE] 0.10.2.1 RC1

Verified my own signatures, ran quickstart and created few Connectors. +1 (binding) On Wed, Apr 12, 2017 at 5:25 PM, Gwen Shapira wrote: > Hello Kafka users, developers, client-developers, friends, romans, > citizens, etc, > > This is the second candidate for release of Apache Kafka 0.10.2.1. >

[jira] [Commented] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969595#comment-15969595 ] Matthias J. Sax commented on KAFKA-5073: Thanks for pointing out [~ijuma]. I just

[jira] [Commented] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969512#comment-15969512 ] Ismael Juma commented on KAFKA-5073: KAFKA-5053 was also merged to 0.10.2 > Kafka Str

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5073: --- Status: Patch Available (was: Open) > Kafka Streams stuck rebalancing after exception thrown

[jira] [Commented] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

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

[GitHub] kafka pull request #2856: KAFKA-5073: Kafka Streams stuck rebalancing after ...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2856 KAFKA-5073: Kafka Streams stuck rebalancing after exception thrown in rebalance listener You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/ka

Re: [VOTE] 0.10.2.1 RC1

+1 (non-binding) Built from the source and ran the quickstart successfully on Ubuntu, Mac, Windows (64 bit). Thank you Gwen for running the release. --Vahid From: Gwen Shapira To: dev@kafka.apache.org, Users Cc: Alexander Ayars Date: 04/12/2017 05:25 PM Subject:[VOTE]

[jira] [Assigned] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5073: -- Assignee: Matthias J. Sax > Kafka Streams stuck rebalancing after exception thrown in r

[jira] [Commented] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969478#comment-15969478 ] Xavier Léauté commented on KAFKA-5073: -- looks like this bug was introduced in the cur

[jira] [Updated] (KAFKA-5069) add controller integration tests

[ https://issues.apache.org/jira/browse/KAFKA-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5069: Status: Patch Available (was: In Progress) > add controller integration tests > ---

[jira] [Updated] (KAFKA-5028) convert kafka controller to a single-threaded event queue model

[ https://issues.apache.org/jira/browse/KAFKA-5028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5028: Status: Patch Available (was: In Progress) > convert kafka controller to a single-threaded event qu

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-5073: - Affects Version/s: (was: 0.10.2.1) > Kafka Streams stuck rebalancing after exception thrown in

[jira] [Updated] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4564: --- Status: Patch Available (was: In Progress) > When the destination brokers are down or misconf

[jira] [Comment Edited] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969442#comment-15969442 ] anugrah edited comment on KAFKA-5049 at 4/14/17 7:42 PM: - [~junrao

Re: Kafka-Streams: Cogroup

Eno, Thanks for the response. The figure was just a restatement of my questions. I have made an attempt at a low level processor and it appears to work but it isn't very pretty and was hoping for something at the streams api level. I have written some code to show an example of how I see the Cogro

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969442#comment-15969442 ] anugrah commented on KAFKA-5049: Hey I am done with the implementation for this. How do I

[jira] [Commented] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails

[ https://issues.apache.org/jira/browse/KAFKA-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969426#comment-15969426 ] Dustin Cote commented on KAFKA-5074: Ah ok I got what you meant. The OfflinePartitionL

[jira] [Commented] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails

[ https://issues.apache.org/jira/browse/KAFKA-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969406#comment-15969406 ] Dustin Cote commented on KAFKA-5074: [~ijuma] I think the unexpected behavior here is

[jira] [Commented] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails

[ https://issues.apache.org/jira/browse/KAFKA-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969378#comment-15969378 ] Ismael Juma commented on KAFKA-5074: I think this is expected. OfflinePartitionLeaderS

[jira] [Created] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails

Dustin Cote created KAFKA-5074: -- Summary: Transition to OnlinePartition without preferred leader in ISR fails Key: KAFKA-5074 URL: https://issues.apache.org/jira/browse/KAFKA-5074 Project: Kafka

[GitHub] kafka pull request #2855: Minor improve streams config parameters

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2855 Minor improve streams config parameters You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka minor-improve-streams-config-parameters Alte

Re: [DISCUSS] ACL operations

On Fri, Apr 14, 2017, at 08:08, Ismael Juma wrote: > That's right Tom. > > In addition, ACLs can apply to more than one topic (we currently only > support `*`, but it would make sense to extend this) and their lifecycle > is > separate from topics (i.e. ACLs can be created for topics that don't >

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-5073: - Description: An exception thrown in the Steams rebalance listener will cause the Kafka consumer c

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-5073: - Description: An exception thrown in the Steams rebalance listener will cause the Kafka consumer c

[jira] [Created] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

Xavier Léauté created KAFKA-5073: Summary: Kafka Streams stuck rebalancing after exception thrown in rebalance listener Key: KAFKA-5073 URL: https://issues.apache.org/jira/browse/KAFKA-5073 Project: K

[jira] [Commented] (KAFKA-4986) Add producer per task support

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

[GitHub] kafka pull request #2854: KAFKA-4986: Adding producer per task (follow-up)

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2854 KAFKA-4986: Adding producer per task (follow-up) - addressing open Github comments from #2773 - test clean-up You can merge this pull request into a Git repository by running: $ git pull ht

[jira] [Commented] (KAFKA-5062) Kafka brokers can accept malformed requests which allocate gigabytes of memory

[ https://issues.apache.org/jira/browse/KAFKA-5062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969210#comment-15969210 ] Ismael Juma commented on KAFKA-5062: Yes, that is reasonable. In fact, we materialize

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

See

[jira] [Commented] (KAFKA-4912) Add check for topic name length

[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969171#comment-15969171 ] Matthias J. Sax commented on KAFKA-4912: Thanks for contributing to Kafka [~soumab

[jira] [Commented] (KAFKA-5062) Kafka brokers can accept malformed requests which allocate gigabytes of memory

[ https://issues.apache.org/jira/browse/KAFKA-5062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969167#comment-15969167 ] Jun Rao commented on KAFKA-5062: Currently, we decompress messages on the broker just to v

[jira] [Commented] (KAFKA-5071) 2017-04-11 18:18:45.574 ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.er

[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969163#comment-15969163 ] Matthias J. Sax commented on KAFKA-5071: [~dnagarajan] Similar to KAFKA-5070 this

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969160#comment-15969160 ] Matthias J. Sax commented on KAFKA-5070: [~dnagarajan] Thanks for report this issu

Re: [DISCUSS] ACL operations

That's right Tom. In addition, ACLs can apply to more than one topic (we currently only support `*`, but it would make sense to extend this) and their lifecycle is separate from topics (i.e. ACLs can be created for topics that don't exist and deleting a topic doesn't delete an associated ACL). Als

[jira] [Updated] (KAFKA-4986) Add producer per task support

[ https://issues.apache.org/jira/browse/KAFKA-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4986: --- Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available) >

[jira] [Commented] (KAFKA-4986) Add producer per task support

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

[GitHub] kafka pull request #2773: KAFKA-4986: Add producer per task support

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2773 --- 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-5068) Optionally print out metrics after running the perf tests

[ https://issues.apache.org/jira/browse/KAFKA-5068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969076#comment-15969076 ] Jun Rao commented on KAFKA-5068: [~huxi_2b], I actually meant all the low level metrics th

Re: [DISCUSS] ACL operations

Colin, Reminder that ACLs don't just apply to topics, but also to consumer groups and cluster operations. It seems like having two sets of APIs, one of which is (topics + acls) and one of which is just acls is more complex than just having acls. On Fri, Apr 14, 2017 at 12:17 AM, Colin McCabe wro

[jira] [Comment Edited] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969038#comment-15969038 ] Soumabrata Chakraborty edited comment on KAFKA-5072 at 4/14/17 1:07 PM:

[jira] [Commented] (KAFKA-4912) Add check for topic name length

[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969047#comment-15969047 ] Soumabrata Chakraborty commented on KAFKA-4912: --- Hi [~sharad.develop] I am a

[jira] [Comment Edited] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969038#comment-15969038 ] Soumabrata Chakraborty edited comment on KAFKA-5072 at 4/14/17 1:07 PM:

[jira] [Commented] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969038#comment-15969038 ] Soumabrata Chakraborty commented on KAFKA-5072: --- Want to assign this story t

[jira] [Updated] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Soumabrata Chakraborty updated KAFKA-5072: -- Affects Version/s: 0.10.2.0 > Kafka topics should allow custom metadata configs

[jira] [Updated] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Soumabrata Chakraborty updated KAFKA-5072: -- Affects Version/s: (was: 0.10.2.0) > Kafka topics should allow custom metada

[jira] [Created] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

Soumabrata Chakraborty created KAFKA-5072: - Summary: Kafka topics should allow custom metadata configs within some config namespace Key: KAFKA-5072 URL: https://issues.apache.org/jira/browse/KAFKA-5072

[jira] [Comment Edited] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

[ https://issues.apache.org/jira/browse/KAFKA-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968922#comment-15968922 ] Nacho Munoz edited comment on KAFKA-4979 at 4/14/17 11:39 AM: --

[jira] [Comment Edited] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

[ https://issues.apache.org/jira/browse/KAFKA-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968922#comment-15968922 ] Nacho Munoz edited comment on KAFKA-4979 at 4/14/17 11:40 AM: --

[jira] [Comment Edited] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

[ https://issues.apache.org/jira/browse/KAFKA-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968922#comment-15968922 ] Nacho Munoz edited comment on KAFKA-4979 at 4/14/17 11:37 AM: --

[jira] [Commented] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

[ https://issues.apache.org/jira/browse/KAFKA-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968922#comment-15968922 ] Nacho Munoz commented on KAFKA-4979: I was playing with the Kafka protocol from Clojur

[jira] [Commented] (KAFKA-3971) Consumers drop from coordinator and cannot reconnect

[ https://issues.apache.org/jira/browse/KAFKA-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968810#comment-15968810 ] justdebugit commented on KAFKA-3971: kafka 0.9 is a very big very big very big very bi

[jira] [Commented] (KAFKA-5068) Optionally print out metrics after running the perf tests

[ https://issues.apache.org/jira/browse/KAFKA-5068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968805#comment-15968805 ] huxi commented on KAFKA-5068: - Seems ProducerPerformance does print the final result for the t

[jira] [Commented] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

[ https://issues.apache.org/jira/browse/KAFKA-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968803#comment-15968803 ] Dan commented on KAFKA-4979: How is the JoinGroupRequest Handcrafted? > Handcrafted JoinGroup

[jira] [Created] (KAFKA-5071) 2017-04-11 18:18:45.574 ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.erro

Dhana created KAFKA-5071: Summary: 2017-04-11 18:18:45.574 ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.errors.ProcessorStateException: task [0_304] Failed

[jira] [Updated] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhana updated KAFKA-5070: - Description: Notes: we run two instance of consumer in two difference machines/nodes. we have 400 partitions. 200

[jira] [Created] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

Dhana created KAFKA-5070: Summary: org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18 Key: KAFKA-5070 URL: https://issues.apache.org/jira/browse/KAFKA-