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

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7245: - Labels: needs-kip newbie (was: beginner needs-kip) > Deprecate WindowStore#put(key, value) >

[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=16621347#comment-16621347 ] Guozhang Wang commented on KAFKA-7245: -- No you're right. I was on an older branch. > Deprecate

[jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1342: - Labels: newbie++ reliability (was: newbie++ newbiee reliability) > Slow controlled shutdowns

[jira] [Updated] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1056: - Labels: newbie++ (was: newbie++ newbiee) > Evenly Distribute Intervals in OffsetIndex >

[jira] [Comment Edited] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621106#comment-16621106 ] James Cheng edited comment on KAFKA-7332 at 9/19/18 8:00 PM: - Thanks

[jira] [Updated] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2758: - Labels: newbie reliability (was: newbiee reliability) > Improve Offset Commit Behavior >

[jira] [Updated] (KAFKA-2865) Improve Request API Error Code Documention

[ https://issues.apache.org/jira/browse/KAFKA-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2865: - Labels: newbie (was: newbiee) > Improve Request API Error Code Documention >

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

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6474: - Labels: newbie (was: beginner newbie) > Rewrite test to use new public TopologyTestDriver >

[jira] [Updated] (KAFKA-7379) send.buffer.bytes should be allowed to set -1 in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7379: - Labels: easyfix newbie (was: beginner easyfix newbie) > send.buffer.bytes should be allowed to

[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=16621243#comment-16621243 ] Guozhang Wang commented on KAFKA-7245: -- [~mjsax] I think the put(key, value) is still used in

[jira] [Commented] (KAFKA-1063) run log cleanup at startup

[ https://issues.apache.org/jira/browse/KAFKA-1063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621175#comment-16621175 ] Sally Ahn commented on KAFKA-1063: -- Was this issue ever addressed in later versions? > run log cleanup

[jira] [Resolved] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

[ https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6594. -- Resolution: Not A Problem > 第二次启动kafka是报错.timeindex: 另一个程序正在使用此文件，进程无法访问。

[jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6889: - Labels: easyfix newbie (was: beginner easyfix) > Fix Streams system test to only specify used

[jira] [Commented] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

[ https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621241#comment-16621241 ] Guozhang Wang commented on KAFKA-6594: -- Hello 兴强, Kafka Community uses the mailing list for

[jira] [Updated] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

[ https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6594: - Labels: starter windows (was: beginner starter windows) >

[jira] [Updated] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7277: - Labels: kip newbie (was: beginner kip newbie) > Migrate Streams API to Duration instead of

[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=16621341#comment-16621341 ] Matthias J. Sax commented on KAFKA-7245: I see only this line:

[jira] [Commented] (KAFKA-7382) We shoud guarantee at lest one replica of partition should be alive when create or update topic

[ https://issues.apache.org/jira/browse/KAFKA-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620641#comment-16620641 ] Suman B N commented on KAFKA-7382: -- Agreed. In alterTopic, it is already handled. In createTopic it

[jira] [Commented] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620723#comment-16620723 ] John Roesler commented on KAFKA-7419: - Hey [~GreenNun], Thanks for the feature request. Can you

[jira] [Commented] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620728#comment-16620728 ] John Roesler commented on KAFKA-7419: - Also, if you haven't already, I'd look at writing a custom

[jira] [Updated] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7419: Component/s: streams > Rolling sum for high frequency sream >

[jira] [Commented] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620699#comment-16620699 ] Steve Malenfant commented on KAFKA-7093: I'm seeing the same behavior after restarting a broker

[jira] [Commented] (KAFKA-7367) Streams should not create state store directories unless they are needed

[ https://issues.apache.org/jira/browse/KAFKA-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620715#comment-16620715 ] John Roesler commented on KAFKA-7367: - FYI, the PR I linked

[jira] [Resolved] (KAFKA-7399) FunctionConversions in Streams-Scala should be private

[ https://issues.apache.org/jira/browse/KAFKA-7399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7399. -- Resolution: Fixed > FunctionConversions in Streams-Scala should be private >

***UNCHECKED*** [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=16620805#comment-16620805 ] Guozhang Wang commented on KAFKA-7245: -- [~mjsax] before anyone taking on this, could you provide

[jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620526#comment-16620526 ] Shantanu Deshmukh commented on KAFKA-4493: -- We are using Kafka 0.10.1.0 and our Kafka producers

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620538#comment-16620538 ] Attila Sasvari commented on KAFKA-7418: --- - I started a discussion thread about the KIP. -

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620541#comment-16620541 ] Srinivas Reddy commented on KAFKA-7418: --- [~asasvari], Thank you for the guidance, I just sent email

[jira] [Commented] (KAFKA-7422) Huge memory consumption (leak?) by Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620486#comment-16620486 ] Shantanu Deshmukh commented on KAFKA-7422: -- What do you mean by valid SSL store and valid SSL

[jira] [Commented] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620507#comment-16620507 ] Viktor Somogyi commented on KAFKA-6794: --- Hi [~smurakozi], are you working on this? In case you

[jira] [Assigned] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7418: Assignee: Srinivas Reddy > Add '--help' option to all available Kafka CLI commands >

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

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7245: --- Description: We want to remove `WindowStore#put(key, value)` – for this, we first need to

[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=16620974#comment-16620974 ] Matthias J. Sax commented on KAFKA-7245: [~panuwat.anawatmongk...@gmail.com] [~guozhang] I

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621021#comment-16621021 ] James Cheng commented on KAFKA-7332: [~lindong], this is somewhat related to

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621050#comment-16621050 ] Dong Lin commented on KAFKA-7332: - [~wushujames] The problem described in KAFKA-4808 says that user today

[jira] [Commented] (KAFKA-7382) We shoud guarantee at lest one replica of partition should be alive when create or update topic

[ https://issues.apache.org/jira/browse/KAFKA-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621066#comment-16621066 ] Suman B N commented on KAFKA-7382: -- Working on this. I already have a fix for this. > We shoud

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621106#comment-16621106 ] James Cheng commented on KAFKA-7332: Thanks [~lindong]. I agree with you that design-wise it makes

[jira] [Commented] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

[ https://issues.apache.org/jira/browse/KAFKA-7332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1662#comment-1662 ] Ismael Juma commented on KAFKA-7332: I think fixing the underlying issue would be good. > Improve

[jira] [Created] (KAFKA-7421) Deadlock in Kafka Connect

Maciej Bryński created KAFKA-7421: - Summary: Deadlock in Kafka Connect Key: KAFKA-7421 URL: https://issues.apache.org/jira/browse/KAFKA-7421 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620252#comment-16620252 ] ASF GitHub Bot commented on KAFKA-7149: --- brary opened a new pull request #5663: KAFKA-7149 Reduce

***UNCHECKED*** [jira] [Updated] (KAFKA-7421) Deadlock in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated KAFKA-7421: -- Issue Type: Bug (was: Improvement) > Deadlock in Kafka Connect > - >

[jira] [Updated] (KAFKA-7421) Deadlock in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated KAFKA-7421: -- Description: I'm getting this deadlock on half of Kafka Connect runs when having two

[jira] [Created] (KAFKA-7423) Kafka compact topic data missing.

Hanlin Liu created KAFKA-7423: - Summary: Kafka compact topic data missing. Key: KAFKA-7423 URL: https://issues.apache.org/jira/browse/KAFKA-7423 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7422) Huge memory consumption (leak?) by Kafka Producer

Shantanu Deshmukh created KAFKA-7422: Summary: Huge memory consumption (leak?) by Kafka Producer Key: KAFKA-7422 URL: https://issues.apache.org/jira/browse/KAFKA-7422 Project: Kafka

[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=16620268#comment-16620268 ] panuwat anawatmongkhon commented on KAFKA-7245: --- Can I take this task? > Deprecate

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620415#comment-16620415 ] Srinivas Reddy commented on KAFKA-7418: --- [~asasvari], Can I start working on this task? I have

[jira] [Comment Edited] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620415#comment-16620415 ] Srinivas Reddy edited comment on KAFKA-7418 at 9/19/18 10:30 AM: -

[jira] [Updated] (KAFKA-7422) Huge memory consumption (leak?) by Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shantanu Deshmukh updated KAFKA-7422: - Environment: OS - AIX 7.1, Java - IBM Java 1.8 (was: RedHat Linux 7.3) > Huge memory

[jira] [Commented] (KAFKA-7422) Huge memory consumption (leak?) by Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620453#comment-16620453 ] Manikumar commented on KAFKA-7422: -- I don't see any object leak in the thread dump.  I can see

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620459#comment-16620459 ] Attila Sasvari commented on KAFKA-7418: --- [~mrsrinivas] sure, it is totally fine with me. However,

[jira] [Commented] (KAFKA-7418) Add '--help' option to all available Kafka CLI commands

[ https://issues.apache.org/jira/browse/KAFKA-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620470#comment-16620470 ] Attila Sasvari commented on KAFKA-7418: --- - Created a KIP: