[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878308#comment-16878308 ] Ryanne Dolan commented on KAFKA-7500: - [~Munamala] Yes, the translateOffsets() works both ways. When

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878277#comment-16878277 ] CHARELS commented on KAFKA-8624: We are sure that our producers' code and consumers' code are ok, But our

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

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878247#comment-16878247 ] Jun Rao commented on KAFKA-8522: Since we are returning the tombstone to the consumer, it may not be

[jira] [Commented] (KAFKA-8628) Auto-generated Kafka RPC code should be able to use zero-copy ByteBuffers

[ https://issues.apache.org/jira/browse/KAFKA-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878238#comment-16878238 ] ASF GitHub Bot commented on KAFKA-8628: --- cmccabe commented on pull request #7032: KAFKA-8628:

[jira] [Created] (KAFKA-8628) Auto-generated Kafka RPC code should be able to use zero-copy ByteBuffers

Colin P. McCabe created KAFKA-8628: -- Summary: Auto-generated Kafka RPC code should be able to use zero-copy ByteBuffers Key: KAFKA-8628 URL: https://issues.apache.org/jira/browse/KAFKA-8628 Project:

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878214#comment-16878214 ] Srikala commented on KAFKA-7500: [~ryannedolan],   Thanks for all your efforts on MM2.  I am also eagerly

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

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878159#comment-16878159 ] ASF GitHub Bot commented on KAFKA-5998: --- vvcephei commented on pull request #7027: KAFKA-5998: fix

[jira] [Created] (KAFKA-8627) Investigate batching on state restore

Sophie Blee-Goldman created KAFKA-8627: -- Summary: Investigate batching on state restore Key: KAFKA-8627 URL: https://issues.apache.org/jira/browse/KAFKA-8627 Project: Kafka Issue Type:

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

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878060#comment-16878060 ] Del Bao commented on KAFKA-4212: Our use case is even simpler. We just want to prevent local state store

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

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878027#comment-16878027 ] Elias Levy commented on KAFKA-4212: --- I am the originator of the issue.  And, yes, for our particular

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

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878024#comment-16878024 ] James Ritt commented on KAFKA-4212: --- Hi [~mjsax], thanks for your input! I'm not the original

[jira] [Commented] (KAFKA-8436) Replace AddOffsetsToTxn request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877989#comment-16877989 ] Boyang Chen commented on KAFKA-8436: [https://github.com/apache/kafka/pull/7015] > Replace

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

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877988#comment-16877988 ] ASF GitHub Bot commented on KAFKA-5998: --- vvcephei commented on pull request #7030: KAFKA-5998: fix

[jira] [Commented] (KAFKA-8617) Replace EndTxn request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877985#comment-16877985 ] ASF GitHub Bot commented on KAFKA-8617: --- abbccdda commented on pull request #7029: KAFKA-8617: Use

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877957#comment-16877957 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 4:32 PM: --- I assume

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877957#comment-16877957 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 4:27 PM: --- I assume

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877957#comment-16877957 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 4:24 PM: --- I assume

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhitao Li(李志涛) updated KAFKA-8624: -- Comment: was deleted (was: That's why they were inconsistent.) > 这边是服务端的kafka，版本是

[jira] [Created] (KAFKA-8626) Group will fall into constant incremental rebalancing with a long non-responsive static member

Boyang Chen created KAFKA-8626: -- Summary: Group will fall into constant incremental rebalancing with a long non-responsive static member Key: KAFKA-8626 URL: https://issues.apache.org/jira/browse/KAFKA-8626

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877958#comment-16877958 ] Zhitao Li(李志涛) commented on KAFKA-8624: --- That's why they were inconsistent. > 这边是服务端的kafka，版本是

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877957#comment-16877957 ] Zhitao Li(李志涛) commented on KAFKA-8624: --- I assume that you write your own production-side code, and

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877955#comment-16877955 ] Zhitao Li(李志涛) commented on KAFKA-8624: --- The reason for my analysis is that it should be caused by

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhitao Li(李志涛) updated KAFKA-8624: -- Attachment: image-2019-07-04-00-18-15-781.png > 这边是服务端的kafka，版本是

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877928#comment-16877928 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 3:51 PM: --- Although

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877928#comment-16877928 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 3:50 PM: --- Although

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877928#comment-16877928 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 3:47 PM: --- If

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877928#comment-16877928 ] Zhitao Li(李志涛) commented on KAFKA-8624: --- If client-side is consistent with server-side version but

[jira] [Updated] (KAFKA-8468) AdminClient.deleteTopics doesn't wait until topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-8468: - Affects Version/s: 2.3.0 > AdminClient.deleteTopics doesn't wait until topic is deleted >

[jira] [Updated] (KAFKA-8625) intra broker data balance stuck

[ https://issues.apache.org/jira/browse/KAFKA-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryne Yang updated KAFKA-8625: - Description: when we used kafka cruise control to invoke kafka's new feature( [feature

[jira] [Updated] (KAFKA-8625) intra broker data balance stuck

[ https://issues.apache.org/jira/browse/KAFKA-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryne Yang updated KAFKA-8625: - Description: when we used kafka cruise control to invoke kafka's new feature([feature

[jira] [Created] (KAFKA-8625) intra broker data balance stuck

Ryne Yang created KAFKA-8625: Summary: intra broker data balance stuck Key: KAFKA-8625 URL: https://issues.apache.org/jira/browse/KAFKA-8625 Project: Kafka Issue Type: Bug Affects Versions:

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877731#comment-16877731 ] ASF GitHub Bot commented on KAFKA-1194: --- manmedia commented on pull request #3838: [KAFKA-1194

[jira] [Commented] (KAFKA-7025) Android client support

[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877667#comment-16877667 ] Leif Yu commented on KAFKA-7025: Is there any plan to fix this issue? > Android client support >

[jira] [Commented] (KAFKA-7025) Android client support

[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877661#comment-16877661 ] gxshao commented on KAFKA-7025: --- Vote !!! > Android client support > -- > >

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877607#comment-16877607 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 8:02 AM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877610#comment-16877610 ] CHARELS commented on KAFKA-8624: It's okay, appreciate > 这边是服务端的kafka，版本是

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877607#comment-16877607 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 8:01 AM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877607#comment-16877607 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 7:58 AM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877607#comment-16877607 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/3/19 7:58 AM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877607#comment-16877607 ] Zhitao Li(李志涛) commented on KAFKA-8624: --- I would like to answer your question. I probably know what

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877602#comment-16877602 ] CHARELS commented on KAFKA-8624: Our version of kafka is 1.0.0, but so many clients that producing

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877583#comment-16877583 ] CHARELS commented on KAFKA-8624: Our version of kafka is 1.0.0, but so many clients that producing

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877560#comment-16877560 ] Jinrui Xu (许晋瑞) edited comment on KAFKA-8624 at 7/3/19 7:29 AM: Could you

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877560#comment-16877560 ] 许晋瑞 commented on KAFKA-8624: Could you provide the versions of client and server that you use? Maybe I can

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

[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877530#comment-16877530 ] lizhitao edited comment on KAFKA-8624 at 7/3/19 7:10 AM: - {color:#00}Please

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877520#comment-16877520 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax] as the KIP accepted shall I close this Jira or any