[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

[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=16410800#comment-16410800 ] ASF GitHub Bot commented on KAFKA-6683: --- ijuma closed pull request #4755: KAFKA-6683; Ensure

[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=16410765#comment-16410765 ] Ismael Juma commented on KAFKA-6705: [~lindong], there's a long-standing Jira about this, it may be

[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

[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=16410672#comment-16410672 ] Dong Lin commented on KAFKA-6705: - Ping [~ijuma] and [~jasong35] for comments. > producer.send() should

[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=16410621#comment-16410621 ] Guozhang Wang commented on KAFKA-6474: -- Filipe would like you to take a look at

[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=16410575#comment-16410575 ] Guozhang Wang commented on KAFKA-3591: -- This is fixed as part of KAFKA-6611. > JmxTool should exit

[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=16410573#comment-16410573 ] ASF GitHub Bot commented on KAFKA-6611: --- guozhangwang closed pull request #4650: KAFKA-6611: PART I,

[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=16410544#comment-16410544 ] Matthias J. Sax commented on KAFKA-6685: Done. [~adireddijagad...@gmail.com] You can assign Jiras

[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=16410534#comment-16410534 ] Guozhang Wang commented on KAFKA-6535: -- I'd vote to still start a KIP though it is a very small one,

[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=16410527#comment-16410527 ] Randall Hauch commented on KAFKA-6685: -- [~adireddijagad...@gmail.com], please ask the Kafka

[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=16410522#comment-16410522 ] John Roesler commented on KAFKA-6437: - I sort of feel like the existing behavior is better than

[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=16410517#comment-16410517 ] ASF GitHub Bot commented on KAFKA-6659: --- mjsax closed pull request #4732: KAFKA-6659: Improve error

[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=16410509#comment-16410509 ] John Roesler commented on KAFKA-6535: - It seems unlikely that there might be folks who just use the

[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=16410487#comment-16410487 ] Gunnar Morling commented on KAFKA-3821: --- Hey [~ewencp], thanks for your extensive reply! I agree

[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=16410366#comment-16410366 ] ASF GitHub Bot commented on KAFKA-6696: --- cmccabe opened a new pull request #4759: KAFKA-6696 Trogdor

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

[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=16410162#comment-16410162 ] John Roesler commented on KAFKA-6474: - Yeah, thanks [~h314to]! I had tried it with just half of that

[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

[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=16410079#comment-16410079 ] Ari Uka edited comment on KAFKA-6679 at 3/22/18 6:36 PM: - So I attempted to

[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=16410082#comment-16410082 ] Matthias J. Sax commented on KAFKA-6535: This ticket is labels as "need kip" -- not sure about

[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=16410079#comment-16410079 ] Ari Uka commented on KAFKA-6679: So I attempted to re-generate one of the topics we had and I've been able

[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=16410078#comment-16410078 ] Attila Sasvari commented on KAFKA-6703: --- There is a call to

[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=16410019#comment-16410019 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax opened a new pull request #4758: KAFKA-6054: Fix

[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=16409993#comment-16409993 ] Ari Uka commented on KAFKA-6679: One thing I'd like to also say is that we are using: FreeBSD with ZFS,

[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=16409957#comment-16409957 ] Antony Stubbs commented on KAFKA-6699: -- Also, what is the replication factor for your topics? Input

[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=16409886#comment-16409886 ] Matthias J. Sax commented on KAFKA-6437: Sounds reasonable to me. The question is, what we want to

[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=16409759#comment-16409759 ] Mariam John commented on KAFKA-6437: In the KafkaStreams we can use the admin client to list all

[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=16409695#comment-16409695 ] UYAR Farid commented on KAFKA-4107: --- There is also another issue I dont know if it's related. When I

[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=16409504#comment-16409504 ] ASF GitHub Bot commented on KAFKA-6670: --- debasishg opened a new pull request #4756: KAFKA-6670:

[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=16406081#comment-16406081 ] Jagadesh Adireddi edited comment on KAFKA-6685 at 3/22/18 12:28 PM: Hi

[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=16409214#comment-16409214 ] Koen De Groote edited comment on KAFKA-6673 at 3/22/18 8:32 AM: That

[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=16409214#comment-16409214 ] Koen De Groote edited comment on KAFKA-6673 at 3/22/18 8:31 AM: That

[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=16409214#comment-16409214 ] Koen De Groote commented on KAFKA-6673: --- That implementation would just do an identity comparison.

[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=16409185#comment-16409185 ] ASF GitHub Bot commented on KAFKA-6683: --- hachikuji opened a new pull request #4755: KAFKA-6683;