[jira] [Commented] (KAFKA-5504) Kafka controller is not getting elected

2017-11-14 Thread Umesh Chaudhary (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253048#comment-16253048 ] Umesh Chaudhary commented on KAFKA-5504: Similar to KAFKA-4277 > Kafka controller

[jira] [Commented] (KAFKA-6185) Selector memory leak with high likelihood of OOM in case of down conversion

2017-11-14 Thread Brett Rann (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253043#comment-16253043 ] Brett Rann commented on KAFKA-6185: --- Our memory problem persists. I have a .hprof from

[jira] [Commented] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

2017-11-14 Thread Sean Glover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252936#comment-16252936 ] Sean Glover commented on KAFKA-5859: I've submitted a PR for this ticket. See descrip

[jira] [Commented] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

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

[jira] [Commented] (KAFKA-4115) Grow default heap settings for distributed Connect from 256M to 1G

2017-11-14 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252713#comment-16252713 ] Randall Hauch commented on KAFKA-4115: -- The {{kafka-run-class.sh}} current [sets the

[jira] [Commented] (KAFKA-4115) Grow default heap settings for distributed Connect from 256M to 1G

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

[jira] [Commented] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-14 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252532#comment-16252532 ] Loïc Monney commented on KAFKA-6168: Hello [~rhauch], First, thank you very much for c

[jira] [Commented] (KAFKA-6170) Add the AdminClient in Streams' KafkaClientSupplier

2017-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252236#comment-16252236 ] ASF GitHub Bot commented on KAFKA-6170: --- GitHub user guozhangwang opened a pull requ

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

2017-11-14 Thread Prasanna Gautam (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16252192#comment-16252192 ] Prasanna Gautam commented on KAFKA-5473: [~junrao] [~ijuma] I have updated the PR

[jira] [Commented] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

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

[jira] [Updated] (KAFKA-6209) Lag is inconsistent when manually committing offset for transactionnal messages

2017-11-14 Thread Fabien Chaillou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabien Chaillou updated KAFKA-6209: --- Description: Hi, I'm using kafka consumers paired with kafka producers to have transactionnal

[jira] [Updated] (KAFKA-6209) Consumer lag is inconsistent when manually committing offset for transactionnal messages

2017-11-14 Thread Fabien Chaillou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabien Chaillou updated KAFKA-6209: --- Summary: Consumer lag is inconsistent when manually committing offset for transactionnal messa

[jira] [Created] (KAFKA-6209) Lag is inconsistent when manually committing offset for transactionnal messages

2017-11-14 Thread Fabien Chaillou (JIRA)
Fabien Chaillou created KAFKA-6209: -- Summary: Lag is inconsistent when manually committing offset for transactionnal messages Key: KAFKA-6209 URL: https://issues.apache.org/jira/browse/KAFKA-6209 Pro

[jira] [Assigned] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

2017-11-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6167: -- Assignee: Matthias J. Sax > Timestamp on streams directory contains a colon, which is a

[jira] [Updated] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

2017-11-14 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5967: - Component/s: streams > Ineffective check of negative value in > CompositeReadOnlyKeyValueStore#ap

[jira] [Assigned] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams

2017-11-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4857: -- Assignee: Matthias J. Sax (was: Guozhang Wang) > Replace StreamsKafkaClient with Admin

[jira] [Created] (KAFKA-6208) Reduce startup time for Kafka Connect workers

2017-11-14 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6208: Summary: Reduce startup time for Kafka Connect workers Key: KAFKA-6208 URL: https://issues.apache.org/jira/browse/KAFKA-6208 Project: Kafka Issue Type: Impro

[jira] [Updated] (KAFKA-6058) Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

2017-11-14 Thread Jorge Quilcate (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Quilcate updated KAFKA-6058: -- Description: {{KafkaAdminClient}} does not allow to get information about consumer groups. This

[jira] [Updated] (KAFKA-6058) Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

2017-11-14 Thread Jorge Quilcate (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Quilcate updated KAFKA-6058: -- Summary: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient (was: Ad

[jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately

2017-11-14 Thread Greg Fodor (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251792#comment-16251792 ] Greg Fodor commented on KAFKA-4281: --- Sadly I'm no longer on the project using Kafka Stre

[jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately

2017-11-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251742#comment-16251742 ] Matthias J. Sax commented on KAFKA-4281: [~gfodor] Can you confirm that your featu

[jira] [Comment Edited] (KAFKA-4281) Should be able to forward aggregation values immediately

2017-11-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251742#comment-16251742 ] Matthias J. Sax edited comment on KAFKA-4281 at 11/14/17 5:08 PM: --

[jira] [Updated] (KAFKA-6207) Include start of record when RecordIsTooLarge

2017-11-14 Thread Tadhg Pearson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tadhg Pearson updated KAFKA-6207: - Description: When a message is too large to be sent (at org.apache.kafka.clients.producer.KafkaPr

[jira] [Created] (KAFKA-6207) Include start of record when RecordIsTooLarge

2017-11-14 Thread Tadhg Pearson (JIRA)
Tadhg Pearson created KAFKA-6207: Summary: Include start of record when RecordIsTooLarge Key: KAFKA-6207 URL: https://issues.apache.org/jira/browse/KAFKA-6207 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4730) Streams does not have an in-memory windowed store

2017-11-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251719#comment-16251719 ] Guozhang Wang commented on KAFKA-4730: -- I do not think so. Plus we do not have an in-

[jira] [Commented] (KAFKA-5254) rethink KTable API overloads

2017-11-14 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251595#comment-16251595 ] Damian Guy commented on KAFKA-5254: --- yep > rethink KTable API overloads > -

[jira] [Commented] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

2017-11-14 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251590#comment-16251590 ] Damian Guy commented on KAFKA-4729: --- @mjsax no it is still RocksDB only > Stores for ks

[jira] [Commented] (KAFKA-4730) Streams does not have an in-memory windowed store

2017-11-14 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251586#comment-16251586 ] Damian Guy commented on KAFKA-4730: --- [~mjsax] no we still don't have an in-memory window

[jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately

2017-11-14 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251583#comment-16251583 ] Damian Guy commented on KAFKA-4281: --- [~mjsax] - yep agreed > Should be able to forward

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-14 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251400#comment-16251400 ] Ben Corlett commented on KAFKA-6194: Topic1 from that log has settings: min.cleanable

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-14 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251382#comment-16251382 ] Ismael Juma commented on KAFKA-6194: [~corlettb], thanks for the logs. You previously

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-14 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251371#comment-16251371 ] Ben Corlett commented on KAFKA-6194: In the past topics have been deleted and recreate

[jira] [Updated] (KAFKA-6194) Server crash while deleting segments

2017-11-14 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Corlett updated KAFKA-6194: --- Attachment: server.log.2017-11-14-03.gz > Server crash while deleting segments > -

[jira] [Commented] (KAFKA-5504) Kafka controller is not getting elected

2017-11-14 Thread Andrey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251161#comment-16251161 ] Andrey commented on KAFKA-5504: --- Looks like configuration issue on our side. Checked *contro

[jira] [Issue Comment Deleted] (KAFKA-5504) Kafka controller is not getting elected

2017-11-14 Thread Andrey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey updated KAFKA-5504: -- Comment: was deleted (was: zkCli shows: - broker 1 is the controller - several seconds later broker 2 is the con

[jira] [Commented] (KAFKA-5504) Kafka controller is not getting elected

2017-11-14 Thread Andrey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251148#comment-16251148 ] Andrey commented on KAFKA-5504: --- zkCli shows: - broker 1 is the controller - several seconds