[jira] [Created] (KAFKA-8624) 这边是服务端的kafka，版本是 kafka_2.11-1.0.0.2，当客户端向主题发送消息的时候抛出如下异常，客户端跟服务端的版本不一致吗？

2019-07-02 Thread CHARELS (JIRA)
CHARELS created KAFKA-8624: -- Summary: 这边是服务端的kafka，版本是 kafka_2.11-1.0.0.2，当客户端向主题发送消息的时候抛出如下异常，客户端跟服务端的版本不一致吗？ Key: KAFKA-8624 URL: https://issues.apache.org/jira/browse/KAFKA-8624 Project: Kafka

[jira] [Commented] (KAFKA-8620) Fix potential race condition in StreamThread state change

2019-07-02 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877440#comment-16877440 ] Boyang Chen commented on KAFKA-8620: In callback #StreamThread.onPartitionsAssigned we will do a

[jira] [Updated] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8611: --- Description: When using DSL in Kafka Streams, data re-partition happens only when

[jira] [Updated] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8611: --- Labels: kip (was: needs-kip) > Make topic optional when using through() operations in DSL >

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

2019-07-02 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877341#comment-16877341 ] Jun Rao commented on KAFKA-8522: [~dhruvilshah] mentioned that the original timestamp of the tombstone

[jira] [Commented] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays

2019-07-02 Thread Steven b (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877315#comment-16877315 ] Steven b commented on KAFKA-8584: - [~suryateja...@gmail.com] - any tips on code paths to look into. I'm

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

2019-07-02 Thread Yanyun Shi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877309#comment-16877309 ] Yanyun Shi commented on KAFKA-6582: --- The Jira status is still Open. Is the issue indeed resolved in

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

2019-07-02 Thread Allen Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877175#comment-16877175 ] Allen Wang commented on KAFKA-7504: --- [~junrao] I tried the configuration you suggested but did not see

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-07-02 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877136#comment-16877136 ] Di Campo edited comment on KAFKA-5998 at 7/2/19 4:52 PM: - Just in case it helps.

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-07-02 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877136#comment-16877136 ] Di Campo commented on KAFKA-5998: - Just in case it helps. I just found it today on 2.1.1 (again, I

[jira] [Commented] (KAFKA-8560) The Kafka protocol generator should support common structures

2019-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877132#comment-16877132 ] ASF GitHub Bot commented on KAFKA-8560: --- gwenshap commented on pull request #6966: KAFKA-8560. The

[jira] [Resolved] (KAFKA-8560) The Kafka protocol generator should support common structures

2019-07-02 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8560. - Resolution: Fixed Fix Version/s: 2.4.0 > The Kafka protocol generator should support

[jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2019-07-02 Thread sandeep gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:37 PM: -- I also

[jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2019-07-02 Thread sandeep gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:35 PM: -- I also

[jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2019-07-02 Thread sandeep gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:33 PM: -- I also

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2019-07-02 Thread sandeep gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877122#comment-16877122 ] sandeep gupta commented on KAFKA-3410: -- I also encountered the same issue. Is there any solution for

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877105#comment-16877105 ] ASF GitHub Bot commented on KAFKA-5998: --- vvcephei commented on pull request #7027: KAFKA-5998: fix

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-07-02 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877103#comment-16877103 ] John Roesler commented on KAFKA-5998: - I've been talking with [~pkleindl] in the above thread, and I

[jira] [Assigned] (KAFKA-8568) MirrorMaker 2.0 resource leak

2019-07-02 Thread Ryanne Dolan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-8568: --- Assignee: Ryanne Dolan > MirrorMaker 2.0 resource leak > - > >

[jira] [Commented] (KAFKA-8622) Snappy Compression Not Working

2019-07-02 Thread Kunal Verma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876898#comment-16876898 ] Kunal Verma commented on KAFKA-8622: [~kaushik srinivas] It worked. Thanks for the quick response.  

[jira] [Commented] (KAFKA-8622) Snappy Compression Not Working

2019-07-02 Thread kaushik srinivas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876874#comment-16876874 ] kaushik srinivas commented on KAFKA-8622: - This can be due to permission issue for the snappy

[jira] [Assigned] (KAFKA-8622) Snappy Compression Not Working

2019-07-02 Thread kaushik srinivas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaushik srinivas reassigned KAFKA-8622: --- Assignee: kaushik srinivas > Snappy Compression Not Working >

[jira] [Created] (KAFKA-8623) KafkaProducer possible deadlock when sending to different topics

2019-07-02 Thread Alexander Bagiev (JIRA)
Alexander Bagiev created KAFKA-8623: --- Summary: KafkaProducer possible deadlock when sending to different topics Key: KAFKA-8623 URL: https://issues.apache.org/jira/browse/KAFKA-8623 Project: Kafka

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

2019-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876836#comment-16876836 ] ASF GitHub Bot commented on KAFKA-5876: --- vitojeng commented on pull request #7026: KAFKA-5876:

[jira] [Updated] (KAFKA-8622) Snappy Compression Not Working

2019-07-02 Thread Kunal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kunal updated KAFKA-8622: - Description: I am trying to produce a message on the broker with compression enabled as snappy. Environment :

[jira] [Created] (KAFKA-8622) Snappy Compression Not Working

2019-07-02 Thread Kunal (JIRA)
Kunal created KAFKA-8622: Summary: Snappy Compression Not Working Key: KAFKA-8622 URL: https://issues.apache.org/jira/browse/KAFKA-8622 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

2019-07-02 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876795#comment-16876795 ] Bruno Cadonna commented on KAFKA-8555: -- https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/23145/

[jira] [Updated] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

2019-07-02 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8555: - Attachment: log-job23145.txt > Flaky test ExampleConnectIntegrationTest#testSourceConnector >

[jira] [Assigned] (KAFKA-8621) KIP-486: Support for pluggable KeyStore and TrustStore

2019-07-02 Thread Thomas Zhou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Zhou reassigned KAFKA-8621: -- Assignee: Thomas Zhou > KIP-486: Support for pluggable KeyStore and TrustStore >

[jira] [Created] (KAFKA-8621) KIP-486: Support for pluggable KeyStore and TrustStore

2019-07-02 Thread MAULIN VASAVADA (JIRA)
MAULIN VASAVADA created KAFKA-8621: -- Summary: KIP-486: Support for pluggable KeyStore and TrustStore Key: KAFKA-8621 URL: https://issues.apache.org/jira/browse/KAFKA-8621 Project: Kafka

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-07-02 Thread Shahar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876720#comment-16876720 ] Shahar commented on KAFKA-7697: --- Is it possible to overcome this issue by simply increasing the number of

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876715#comment-16876715 ] Matthias J. Sax commented on KAFKA-7869: [~dongjin] It's to assigned the ticket to yourself and

[jira] [Assigned] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7869: -- Assignee: Lee Dongjin > Refactor RocksDBConfigSetter API to separate DBOptions and

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876710#comment-16876710 ] Matthias J. Sax commented on KAFKA-4212: Isn't RocksDB TTL based on wall-clock time? I think we

[jira] [Updated] (KAFKA-8620) Fix potential race condition in StreamThread state change

2019-07-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8620: --- Component/s: streams > Fix potential race condition in StreamThread state change >