[jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410894#comment-16410894 ] Jason Gustafson commented on KAFKA-6683: [~chema.sanchez] Thanks a lot for the log

[jira] [Commented] (KAFKA-6705) producer.send() should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410876#comment-16410876 ] Dong Lin commented on KAFKA-6705: - [~ijuma] Thanks for the information. I will search for

[jira] [Updated] (KAFKA-6705) producer.send() should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6705: Description: Currently producer.send() may block on metadata for up to max.block.ms. This behavior is well d

[jira] [Resolved] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6683. Resolution: Fixed Fix Version/s: 1.1.0 > ReplicaFetcher crashes with "Attempted to complete a

[jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410800#comment-16410800 ] ASF GitHub Bot commented on KAFKA-6683: --- ijuma closed pull request #4755: KAFKA-6683

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

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

[jira] [Updated] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6127: --- Description: Streams uses three consumer APIs that can block infinite: {{commitSync()}}, {{co

[jira] [Updated] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6127: --- Description: Streams uses three consumer APIs that can block infinite: {{commitSync()}}, {{co

[jira] [Commented] (KAFKA-6705) producer.send() should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410765#comment-16410765 ] Ismael Juma commented on KAFKA-6705: [~lindong], there's a long-standing Jira about th

[jira] [Assigned] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6685: Assignee: Jagadesh Adireddi > Connect deserialization log message should distinguis

[jira] [Commented] (KAFKA-6705) producer.send() should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410672#comment-16410672 ] Dong Lin commented on KAFKA-6705: - Ping [~ijuma] and [~jasong35] for comments. > producer

[jira] [Created] (KAFKA-6705) producer.send() should be non-blocking

Dong Lin created KAFKA-6705: --- Summary: producer.send() should be non-blocking Key: KAFKA-6705 URL: https://issues.apache.org/jira/browse/KAFKA-6705 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410621#comment-16410621 ] Guozhang Wang commented on KAFKA-6474: -- Filipe would like you to take a look at http

[jira] [Commented] (KAFKA-3591) JmxTool should exit out if a provided query matches no values

[ https://issues.apache.org/jira/browse/KAFKA-3591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410575#comment-16410575 ] Guozhang Wang commented on KAFKA-3591: -- This is fixed as part of KAFKA-6611. > JmxTo

[jira] [Commented] (KAFKA-6611) Re-write simple benchmark in system tests with JMXTool

[ https://issues.apache.org/jira/browse/KAFKA-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410573#comment-16410573 ] ASF GitHub Bot commented on KAFKA-6611: --- guozhangwang closed pull request #4650: KAF

[jira] [Commented] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410544#comment-16410544 ] Matthias J. Sax commented on KAFKA-6685: Done. [~adireddijagad...@gmail.com] You c

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410534#comment-16410534 ] Guozhang Wang commented on KAFKA-6535: -- I'd vote to still start a KIP though it is a

[jira] [Commented] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410527#comment-16410527 ] Randall Hauch commented on KAFKA-6685: -- [~adireddijagad...@gmail.com], please ask the

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410522#comment-16410522 ] John Roesler commented on KAFKA-6437: - I sort of feel like the existing behavior is be

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410517#comment-16410517 ] ASF GitHub Bot commented on KAFKA-6659: --- mjsax closed pull request #4732: KAFKA-6659

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410509#comment-16410509 ] John Roesler commented on KAFKA-6535: - It seems unlikely that there might be folks who

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410487#comment-16410487 ] Gunnar Morling commented on KAFKA-3821: --- Hey [~ewencp], thanks for your extensive re

[jira] [Commented] (KAFKA-6696) Trogdor should support destroying tasks

[ https://issues.apache.org/jira/browse/KAFKA-6696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410366#comment-16410366 ] ASF GitHub Bot commented on KAFKA-6696: --- cmccabe opened a new pull request #4759: KA

[jira] [Created] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException

Bill Bejeck created KAFKA-6704: -- Summary: Checking hasNext from SegementIterator could throw InvalidStateStoreException Key: KAFKA-6704 URL: https://issues.apache.org/jira/browse/KAFKA-6704 Project: Kaf

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410162#comment-16410162 ] John Roesler commented on KAFKA-6474: - Yeah, thanks [~h314to]! I had tried it with jus

[jira] [Updated] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari updated KAFKA-6703: -- Description: Scenario: - MM whitelabel regexp matches multiple topics - destination cluster ha

[jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410079#comment-16410079 ] Ari Uka edited comment on KAFKA-6679 at 3/22/18 6:36 PM: - So I att

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410082#comment-16410082 ] Matthias J. Sax commented on KAFKA-6535: This ticket is labels as "need kip" -- no

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410079#comment-16410079 ] Ari Uka commented on KAFKA-6679: So I attempted to re-generate one of the topics we had an

[jira] [Commented] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410078#comment-16410078 ] Attila Sasvari commented on KAFKA-6703: --- There is a call to [ensureCoordinatorReady

[jira] [Created] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

Attila Sasvari created KAFKA-6703: - Summary: MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader Key: KAFKA-6703 URL: https://issues.apache.org/jira/browse/KAFKA-6703

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

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

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409993#comment-16409993 ] Ari Uka commented on KAFKA-6679: One thing I'd like to also say is that we are using: Fre

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409957#comment-16409957 ] Antony Stubbs commented on KAFKA-6699: -- Also, what is the replication factor for your

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409886#comment-16409886 ] Matthias J. Sax commented on KAFKA-6437: Sounds reasonable to me. The question is,

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409759#comment-16409759 ] Mariam John commented on KAFKA-6437: In the KafkaStreams we can use the admin client t

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409695#comment-16409695 ] UYAR Farid commented on KAFKA-4107: --- There is also another issue I dont know if it's rel

[jira] [Commented] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409504#comment-16409504 ] ASF GitHub Bot commented on KAFKA-6670: --- debasishg opened a new pull request #4756:

[jira] [Comment Edited] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406081#comment-16406081 ] Jagadesh Adireddi edited comment on KAFKA-6685 at 3/22/18 12:28 PM:

[jira] [Comment Edited] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals.

[ https://issues.apache.org/jira/browse/KAFKA-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409214#comment-16409214 ] Koen De Groote edited comment on KAFKA-6673 at 3/22/18 8:32 AM:

[jira] [Comment Edited] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals.

[ https://issues.apache.org/jira/browse/KAFKA-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409214#comment-16409214 ] Koen De Groote edited comment on KAFKA-6673 at 3/22/18 8:31 AM:

[jira] [Commented] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals.

[ https://issues.apache.org/jira/browse/KAFKA-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409214#comment-16409214 ] Koen De Groote commented on KAFKA-6673: --- That implementation would just do an identi

[jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409185#comment-16409185 ] ASF GitHub Bot commented on KAFKA-6683: --- hachikuji opened a new pull request #4755: