[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270342#comment-16270342 ] Seweryn Habdank-Wojewodzki commented on KAFKA-6260: --- BTW the other bug:

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270341#comment-16270341 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- BTW the other bug:

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270338#comment-16270338 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 7:54 AM: ---

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270338#comment-16270338 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- [~mjsax] What do yo

[jira] [Resolved] (KAFKA-6257) KafkaConsumer was hung when bootstrap servers was not existed

[ https://issues.apache.org/jira/browse/KAFKA-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-6257. - Resolution: Duplicate Closing this as duplicate since no contradicting information was added. > K

[jira] [Commented] (KAFKA-6048) Support negative record timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270062#comment-16270062 ] james chien commented on KAFKA-6048: [~mjsax] ok!! > Support negative record timestam

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

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

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269853#comment-16269853 ] Jiangjie Qin commented on KAFKA-6264: - [~hachikuji] Yes, that may be a workaround. If

[jira] [Updated] (KAFKA-6271) FileInputStream.skip function can return 0 when the file is corrupted, causing an infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6271: --- Component/s: KafkaConnect > FileInputStream.skip function can return 0 when the file is corrup

[jira] [Updated] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6252: - Priority: Critical (was: Major) > A metric named 'XX' already exists, can't register another one.

[jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269781#comment-16269781 ] Randall Hauch commented on KAFKA-6252: -- This also happens when a connector does not p

[jira] [Updated] (KAFKA-6275) Extend consumer offset reset tool to support deletion

[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-6275: --- Labels: kip (was: needs-kip) > Extend consumer offset reset tool to support deletion > --

[jira] [Resolved] (KAFKA-6279) Connect metrics do not get cleaned up for a source connector that doesn't stop properly

[ https://issues.apache.org/jira/browse/KAFKA-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6279. -- Resolution: Duplicate > Connect metrics do not get cleaned up for a source connector that doesn'

[jira] [Commented] (KAFKA-6279) Connect metrics do not get cleaned up for a source connector that doesn't stop properly

[ https://issues.apache.org/jira/browse/KAFKA-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269776#comment-16269776 ] Randall Hauch commented on KAFKA-6279: -- This was recently reported as KAFKA-6252, so

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

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

[jira] [Commented] (KAFKA-6278) Allow multiple concurrent transactions on a single producer

[ https://issues.apache.org/jira/browse/KAFKA-6278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269597#comment-16269597 ] Jason Gustafson commented on KAFKA-6278: Thanks for the report. This was an unfort

[jira] [Comment Edited] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials

[ https://issues.apache.org/jira/browse/KAFKA-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269578#comment-16269578 ] Vahid Hashemian edited comment on KAFKA-6118 at 11/28/17 10:19 PM: -

[jira] [Commented] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials

[ https://issues.apache.org/jira/browse/KAFKA-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269578#comment-16269578 ] Vahid Hashemian commented on KAFKA-6118: I also hit this today with one of my PRs:

[jira] [Commented] (KAFKA-6255) Add ProduceBench to Trogdor

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

[jira] [Resolved] (KAFKA-6255) Add ProduceBench to Trogdor

[ https://issues.apache.org/jira/browse/KAFKA-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6255. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4245 [https://git

[jira] [Created] (KAFKA-6280) Allow for additional archive types to be loaded from plugin.path in Connect

Konstantine Karantasis created KAFKA-6280: - Summary: Allow for additional archive types to be loaded from plugin.path in Connect Key: KAFKA-6280 URL: https://issues.apache.org/jira/browse/KAFKA-6280

[jira] [Commented] (KAFKA-5526) KIP-175: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

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

[jira] [Commented] (KAFKA-5526) KIP-175: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

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

[jira] [Updated] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5154: - Fix Version/s: 0.11.0.0 > Kafka Streams throws NPE during rebalance >

[jira] [Updated] (KAFKA-6279) Connect metrics do not get cleaned up for a source connector that doesn't stop properly

[ https://issues.apache.org/jira/browse/KAFKA-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6279: - Priority: Critical (was: Major) > Connect metrics do not get cleaned up for a source connector th

[jira] [Commented] (KAFKA-6274) Improve KTable Source state store auto-generated names

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

[jira] [Resolved] (KAFKA-6274) Improve KTable Source state store auto-generated names

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

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269266#comment-16269266 ] Nick Travers commented on KAFKA-4669: - We hit this again in production, running 0.11.0

[jira] [Updated] (KAFKA-6265) GlobalKTable missing #queryableStoreName()

[ https://issues.apache.org/jira/browse/KAFKA-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6265: --- Labels: beginner needs-kip newbie (was: ) > GlobalKTable missing #queryableStoreName() >

[jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient

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

[jira] [Created] (KAFKA-6279) Connect metrics do not get cleaned up for a source connector that doesn't stop properly

Randall Hauch created KAFKA-6279: Summary: Connect metrics do not get cleaned up for a source connector that doesn't stop properly Key: KAFKA-6279 URL: https://issues.apache.org/jira/browse/KAFKA-6279

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

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

[jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269058#comment-16269058 ] Andreas Schroeder commented on KAFKA-6269: -- Hi again [~mjsax], I'm back with some

[jira] [Assigned] (KAFKA-6048) Support negative record timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6048: -- Assignee: Konstantin Chukhlomin (was: james chien) > Support negative record timestamp

[jira] [Commented] (KAFKA-6048) Support negative record timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269034#comment-16269034 ] Matthias J. Sax commented on KAFKA-6048: [~james.c] It seems you did loose interes

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269010#comment-16269010 ] Matthias J. Sax commented on KAFKA-5882: Hmmm... Can you do a `topologyBuilder.bui

[jira] [Commented] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268997#comment-16268997 ] Matthias J. Sax commented on KAFKA-6249: Thanks. I understand what you are saying.

[jira] [Resolved] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6249. Resolution: Duplicate > Interactive query downtime when node goes down even with standby rep

[jira] [Commented] (KAFKA-1489) Global threshold on data retention size

[ https://issues.apache.org/jira/browse/KAFKA-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268849#comment-16268849 ] Jeffrey Zampieron commented on KAFKA-1489: -- I'd like to propose thinking about th

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268757#comment-16268757 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- It is still the sam

[jira] [Commented] (KAFKA-6249) Interactive query downtime when node goes down even with standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268753#comment-16268753 ] Charles Crain commented on KAFKA-6249: -- It is possible I am seeing the delay due to t

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268731#comment-16268731 ] Edoardo Comar commented on KAFKA-1120: -- Interestingly using [~wushujames] script in [