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

2018-09-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615537#comment-16615537 ] ASF GitHub Bot commented on KAFKA-7192: --- mjsax opened a new pull request #5657: KAFKA-7192: Wipe

[jira] [Commented] (KAFKA-7408) Truncate to LSO on unclean leader election

2018-09-14 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615492#comment-16615492 ] Jun Rao commented on KAFKA-7408: It does seem that truncating to LSO handles unclean leader election

[jira] [Assigned] (KAFKA-7235) Use brokerZkNodeVersion to prevent broker from processing outdated controller request

2018-09-14 Thread Zhanxiang (Patrick) Huang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanxiang (Patrick) Huang reassigned KAFKA-7235: Assignee: Zhanxiang (Patrick) Huang (was: Dong Lin) > Use

[jira] [Commented] (KAFKA-7413) Replace slave terminology with follower in website

2018-09-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615477#comment-16615477 ] John Roesler commented on KAFKA-7413: - Thank you, I also find the use of the word "slave" in software

[jira] [Created] (KAFKA-7416) kerberos credentials not being refreshed

2018-09-14 Thread Tyler Monahan (JIRA)
Tyler Monahan created KAFKA-7416: Summary: kerberos credentials not being refreshed Key: KAFKA-7416 URL: https://issues.apache.org/jira/browse/KAFKA-7416 Project: Kafka Issue Type: Bug

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

2018-09-14 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615354#comment-16615354 ] Navinder Brar commented on KAFKA-7149: -- Yes, I agree with all you explained above. But for all the

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

2018-09-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615339#comment-16615339 ] Guozhang Wang commented on KAFKA-7149: -- The {{Assignment}} object is sent one for each consumer,

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

2018-09-14 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615271#comment-16615271 ] Navinder Brar edited comment on KAFKA-7149 at 9/14/18 7:24 PM: --- Hi

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

2018-09-14 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615271#comment-16615271 ] Navinder Brar commented on KAFKA-7149: -- Hi [~guozhang] What I mean is currently the Assignment which

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

2018-09-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7192: --- Affects Version/s: 0.11.0.3 > State-store can desynchronise with changelog >

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

2018-09-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7192: --- Fix Version/s: 0.11.0.4 > State-store can desynchronise with changelog >

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

2018-09-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615257#comment-16615257 ] ASF GitHub Bot commented on KAFKA-7192: --- mjsax closed pull request #5641: KAFKA-7192: Wipe out

[jira] [Resolved] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

2018-09-14 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7280. Resolution: Fixed Fix Version/s: (was: 1.1.2) > ConcurrentModificationException

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

2018-09-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615254#comment-16615254 ] Guozhang Wang commented on KAFKA-7149: -- [~NaviBrar] Thanks for looking into this!! Could you clarify

[jira] [Commented] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

2018-09-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615242#comment-16615242 ] ASF GitHub Bot commented on KAFKA-7280: --- hachikuji closed pull request #5495: KAFKA-7280:

[jira] [Updated] (KAFKA-7415) OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

2018-09-14 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-7415: Description: If the follower's last appended epoch is ahead of the leader's last appended epoch, 

[jira] [Created] (KAFKA-7415) OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW

2018-09-14 Thread Anna Povzner (JIRA)
Anna Povzner created KAFKA-7415: --- Summary: OffsetsForLeaderEpoch may incorrectly respond with undefined epoch causing truncation to HW Key: KAFKA-7415 URL: https://issues.apache.org/jira/browse/KAFKA-7415

[jira] [Commented] (KAFKA-7414) Do not fail broker on out of range offsets in replica fetcher

2018-09-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615172#comment-16615172 ] ASF GitHub Bot commented on KAFKA-7414: --- hachikuji opened a new pull request #5654: KAFKA-7414; Out

[jira] [Created] (KAFKA-7414) Do not fail broker on out of range offsets in replica fetcher

2018-09-14 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7414: -- Summary: Do not fail broker on out of range offsets in replica fetcher Key: KAFKA-7414 URL: https://issues.apache.org/jira/browse/KAFKA-7414 Project: Kafka

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

2018-09-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614946#comment-16614946 ] John Roesler commented on KAFKA-4609: - The first step in resolving this would be to create a repro

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

2018-09-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614943#comment-16614943 ] John Roesler commented on KAFKA-4609: - [~damianguy]: I think you left this assigned to yourself by

[jira] [Assigned] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results

2018-09-14 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-4609: --- Assignee: (was: Damian Guy) > KTable/KTable join followed by groupBy and

[jira] [Commented] (KAFKA-845) Re-implement shallow iteration on 0.8.1

2018-09-14 Thread Chris Johnson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614716#comment-16614716 ] Chris Johnson commented on KAFKA-845: - [~junrao], this regression has been unresolved from 0.8 all the

[jira] [Created] (KAFKA-7413) Replace slave terminology with follower in website

2018-09-14 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created KAFKA-7413: - Summary: Replace slave terminology with follower in website Key: KAFKA-7413 URL: https://issues.apache.org/jira/browse/KAFKA-7413 Project: Kafka

[jira] [Updated] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

2018-09-14 Thread Michal Turek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Turek updated KAFKA-7412: Description: Hi there, I have probably found a bug in Java Kafka producer client. Scenario &

[jira] [Created] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

2018-09-14 Thread Michal Turek (JIRA)
Michal Turek created KAFKA-7412: --- Summary: Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running Key: KAFKA-7412 URL: https://issues.apache.org/jira/browse/KAFKA-7412

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

2018-09-14 Thread Navinder Brar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16611610#comment-16611610 ] Navinder Brar edited comment on KAFKA-7149 at 9/14/18 8:01 AM: --- [~guozhang]