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

2019-07-02 Thread lizhitao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877530#comment-16877530 ] lizhitao commented on KAFKA-8624: - {color:#00}Please give the client-side and server-

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-07-02 Thread Omkar Mestry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877520#comment-16877520 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax] as the KIP accepted shall I close thi

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

[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&focusedCommentId=16877440#comment-16877440 ] Boyang Chen commented on KAFKA-8620: In callback #StreamThread.onPartitionsAssigned w

[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 key-changi

[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&focusedCommentId=16877341#comment-16877341 ] Jun Rao commented on KAFKA-8522: [~dhruvilshah] mentioned that the original timestamp of

[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&focusedCommentId=16877315#comment-16877315 ] Steven b commented on KAFKA-8584: - [~suryateja...@gmail.com] - any tips on code paths to

[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&focusedCommentId=16877309#comment-16877309 ] Yanyun Shi commented on KAFKA-6582: --- The Jira status is still Open. Is the issue indeed

[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&focusedCommentId=16877175#comment-16877175 ] Allen Wang commented on KAFKA-7504: --- [~junrao] I tried the configuration you suggested

[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&focusedCommentId=16877136#comment-16877136 ] Di Campo edited comment on KAFKA-5998 at 7/2/19 4:52 PM: - Just in

[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&focusedCommentId=16877136#comment-16877136 ] Di Campo commented on KAFKA-5998: - Just in case it helps. I just found it today on 2.1.1

[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&focusedCommentId=16877132#comment-16877132 ] ASF GitHub Bot commented on KAFKA-8560: --- gwenshap commented on pull request #6966:

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

[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&focusedCommentId=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:37 PM: -

[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&focusedCommentId=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:35 PM: -

[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&focusedCommentId=16877122#comment-16877122 ] sandeep gupta edited comment on KAFKA-3410 at 7/2/19 4:33 PM: -

[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&focusedCommentId=16877122#comment-16877122 ] sandeep gupta commented on KAFKA-3410: -- I also encountered the same issue. Is there

[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&focusedCommentId=16877105#comment-16877105 ] ASF GitHub Bot commented on KAFKA-5998: --- vvcephei commented on pull request #7027:

[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&focusedCommentId=16877103#comment-16877103 ] John Roesler commented on KAFKA-5998: - I've been talking with [~pkleindl] in the abov

[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&focusedCommentId=16876898#comment-16876898 ] Kunal Verma commented on KAFKA-8622: [~kaushik srinivas] It worked. Thanks for the qu

[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&focusedCommentId=16876874#comment-16876874 ] kaushik srinivas commented on KAFKA-8622: - This can be due to permission issue fo

[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&focusedCommentId=16876836#comment-16876836 ] ASF GitHub Bot commented on KAFKA-5876: --- vitojeng commented on pull request #7026:

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

[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&focusedCommentId=16876795#comment-16876795 ] Bruno Cadonna commented on KAFKA-8555: -- https://builds.apache.org/job/kafka-pr-jdk8-

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