[jira] [Commented] (KAFKA-7131) Update release script to generate announcement email text

[ https://issues.apache.org/jira/browse/KAFKA-7131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555168#comment-16555168 ] bibin sebastian commented on KAFKA-7131: can i pick this up? i can work on this with some

[jira] [Created] (KAFKA-7203) Improve Streams StickyTaskAssingor

Guozhang Wang created KAFKA-7203: Summary: Improve Streams StickyTaskAssingor Key: KAFKA-7203 URL: https://issues.apache.org/jira/browse/KAFKA-7203 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7144. -- Resolution: Fixed Fix Version/s: 2.1.0 > Kafka Streams doesn't properly balance

[jira] [Commented] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555137#comment-16555137 ] ASF GitHub Bot commented on KAFKA-7144: --- guozhangwang closed pull request #5390: KAFKA-7144: Fix

[jira] [Commented] (KAFKA-7024) Rocksdb state directory should be created before opening the DB

[ https://issues.apache.org/jira/browse/KAFKA-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555132#comment-16555132 ] Guozhang Wang commented on KAFKA-7024: -- [~abhishek.agarwal] I've added you to the contributor list,

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555049#comment-16555049 ] Guozhang Wang commented on KAFKA-7192: -- Hello [~jonmbates] Thanks for reporting this issue. I've

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555045#comment-16555045 ] ASF GitHub Bot commented on KAFKA-7192: --- guozhangwang opened a new pull request #5421: KAFKA-7192:

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555038#comment-16555038 ] Matthias J. Sax commented on KAFKA-6793: [~vahid] you are right and it is known – it's by design

[jira] [Comment Edited] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554980#comment-16554980 ] Vahid Hashemian edited comment on KAFKA-6793 at 7/25/18 1:09 AM: - This

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554909#comment-16554909 ] ErikPearson commented on KAFKA-7044: Seems I needed to escape those leading braces in the for/if. 

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554905#comment-16554905 ] ErikPearson commented on KAFKA-7044: I tried increasing the Duration explicitly in

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554817#comment-16554817 ] Guozhang Wang commented on KAFKA-6520: -- Just want to re-emphasize that, it is not only a Streams

[jira] [Created] (KAFKA-7202) Support multiple auto-generated docs formats

Joel Hamill created KAFKA-7202: -- Summary: Support multiple auto-generated docs formats Key: KAFKA-7202 URL: https://issues.apache.org/jira/browse/KAFKA-7202 Project: Kafka Issue Type: New

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554771#comment-16554771 ] Matthias J. Sax commented on KAFKA-6520: As the ticket description above says: > It would be

[jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4969: --- Description: Currently, {{StreamPartitionsAssigner}} does not distinguish different "types" of

[jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4969: --- Description: Currently, {{StreamPartitionsAssigner}} does not distinguish different "types" of

[jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-4969: --- Description: Currently, {{StreamPartitionsAssigner}} does not distinguish different "types" of

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554739#comment-16554739 ] Harjit Singh commented on KAFKA-6520: - Should the stream stop running or log an error  ? > When a

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554730#comment-16554730 ] Matthias J. Sax commented on KAFKA-6520: [~harjitdotsingh] Well. That is what this ticket is

[jira] [Comment Edited] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554726#comment-16554726 ] Harjit Singh edited comment on KAFKA-6520 at 7/24/18 7:50 PM: -- Even if I

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554726#comment-16554726 ] Harjit Singh commented on KAFKA-6520: - Even if I don't run Kafka  the wordCountDemo program doesn't

[jira] [Resolved] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7195. -- Resolution: Fixed Fix Version/s: 2.0.0 > StreamStreamJoinIntegrationTest fails in 2.0

[jira] [Resolved] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2318. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists in newer

[jira] [Resolved] (KAFKA-3040) Broker didn't report new data after change in leader

[ https://issues.apache.org/jira/browse/KAFKA-3040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3040. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists in newer

[jira] [Resolved] (KAFKA-2890) Strange behaviour during partitions reassignment.

[ https://issues.apache.org/jira/browse/KAFKA-2890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2890. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists in newer

[jira] [Created] (KAFKA-7201) Optimize repartition operations

Bill Bejeck created KAFKA-7201: -- Summary: Optimize repartition operations Key: KAFKA-7201 URL: https://issues.apache.org/jira/browse/KAFKA-7201 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-2968) Refactor ReplicaManager to be optimal for o.a.k.c requests

[ https://issues.apache.org/jira/browse/KAFKA-2968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2968. -- Resolution: Fixed Closing this as scala request/responses classes are removed and ReplicaManager is 

[jira] [Created] (KAFKA-7200) Preserve serdes used

Bill Bejeck created KAFKA-7200: -- Summary: Preserve serdes used Key: KAFKA-7200 URL: https://issues.apache.org/jira/browse/KAFKA-7200 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-2969) Refactor MetadataCache to be optimal for o.a.k.c requests

[ https://issues.apache.org/jira/browse/KAFKA-2969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2969. -- Resolution: Fixed Closing this as scala request/responses classes are removed and MetadataCache

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554586#comment-16554586 ] Matthias J. Sax commented on KAFKA-5882: Thanks for sharing your findings [~laven]! >

[jira] [Resolved] (KAFKA-2075) Validate that all kafka.api requests has been removed and clean up compatibility code

[ https://issues.apache.org/jira/browse/KAFKA-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2075. -- Resolution: Fixed Old scala request/reponse classes are removed as part of KAFKA-2983: > Validate

[jira] [Assigned] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7144: -- Assignee: Bill Bejeck > Kafka Streams doesn't properly balance partition assignment >

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554541#comment-16554541 ] Adrian McCague commented on KAFKA-6767: --- Also perhaps a coincidence but topology was running fine

[jira] [Created] (KAFKA-7199) Support BigInteger data type

Jiri Pechanec created KAFKA-7199: Summary: Support BigInteger data type Key: KAFKA-7199 URL: https://issues.apache.org/jira/browse/KAFKA-7199 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7195: -- Fix Version/s: (was: 2.0.0) > StreamStreamJoinIntegrationTest fails in 2.0 Jenkins >

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554237#comment-16554237 ] Laven Sukumaran commented on KAFKA-5882: Thanks for the update [~mjsax], it helped fixed the

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554236#comment-16554236 ] Laven Sukumaran commented on KAFKA-6388: . > Error while trying to roll a segment that already

[jira] [Issue Comment Deleted] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Laven Sukumaran updated KAFKA-6388: --- Comment: was deleted (was: .) > Error while trying to roll a segment that already exists >

[jira] [Updated] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7195: -- Affects Version/s: 2.0.0 Fix Version/s: 2.0.0 > StreamStreamJoinIntegrationTest fails

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554059#comment-16554059 ] Adrian McCague commented on KAFKA-6767: --- Hi [~guozhang] we are seeing this issue as well on a

[jira] [Commented] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554004#comment-16554004 ] ASF GitHub Bot commented on KAFKA-7195: --- rajinisivaram closed pull request #5418: KAFKA-7195: Fix

[jira] [Commented] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554006#comment-16554006 ] Rajini Sivaram commented on KAFKA-7195: --- [~omkreddy] I have merged the PR to 2.0 branch, but

[jira] [Assigned] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7195: - Assignee: Manikumar > StreamStreamJoinIntegrationTest fails in 2.0 Jenkins >

[jira] [Resolved] (KAFKA-7194) Error deserializing assignment after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7194. --- Resolution: Fixed Reviewer: Konstantine Karantasis Fix Version/s: 2.0.0 >

[jira] [Commented] (KAFKA-7194) Error deserializing assignment after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553954#comment-16553954 ] ASF GitHub Bot commented on KAFKA-7194: --- rajinisivaram closed pull request #5417: KAFKA-7194; Fix

[jira] [Updated] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojing zhou updated KAFKA-7078: - Attachment: image-2018-07-24-14-23-19-183.png > Kafka 1.0.1 Broker version crashes when deleting

[jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553861#comment-16553861 ] xiaojing zhou commented on KAFKA-7078: -- !screenshot-1.png! The weird thing is that, the last update