[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914740#comment-16914740 ] Chris Pettitt commented on KAFKA-8831: -- [~vinoth]:   Here's Sophie's guess: {code:

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Component/s: streams > Joining a new instance sometimes does not cause rebalancing >

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Attachment: (was: fail.log) > Joining a new instance sometimes does not cause rebalancing > -

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914709#comment-16914709 ] Chris Pettitt commented on KAFKA-8831: -- Thanks Vinoth! > Joining a new instance som

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Attachment: fail.log > Joining a new instance sometimes does not cause rebalancing >

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914704#comment-16914704 ] Vinoth Chandar commented on KAFKA-8831: --- I am also facing this, on a similar setup.

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Description: See attached log. The application is in a REBALANCING state. The second instance jo

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Attachment: fail.log > Joining a new instance sometimes does not cause rebalancing >

[jira] [Updated] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt updated KAFKA-8831: - Description: See attached log. The second instance joins a bit after the first instance (~250ms)

[jira] [Created] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-23 Thread Chris Pettitt (Jira)
Chris Pettitt created KAFKA-8831: Summary: Joining a new instance sometimes does not cause rebalancing Key: KAFKA-8831 URL: https://issues.apache.org/jira/browse/KAFKA-8831 Project: Kafka Is

[jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration

2019-08-23 Thread James Cheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8813: --- Description: In Partition.createLog we do: {code:java} val config = LogConfig.fromProps(logManager.cu

[jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration

2019-08-23 Thread James Cheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8813: --- Description: In Partition.createLog we do: {{val config = LogConfig.fromProps(logManager.currentDefa

[jira] [Resolved] (KAFKA-8753) Add JMX for number of topics marked for deletion

2019-08-23 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8753. Fix Version/s: 2.4.0 Resolution: Fixed > Add JMX for number of topics marked for del

[jira] [Commented] (KAFKA-8753) Add JMX for number of topics marked for deletion

2019-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914598#comment-16914598 ] ASF GitHub Bot commented on KAFKA-8753: --- hachikuji commented on pull request #7156:

[jira] [Updated] (KAFKA-8830) KIP-512: Adding headers to RecordMetaData

2019-08-23 Thread Renuka Metukuru (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renuka Metukuru updated KAFKA-8830: --- Description: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-512%3AAdding+headers+to+R

[jira] [Created] (KAFKA-8830) KIP-512: Adding headers to RecordMetaData

2019-08-23 Thread Renuka Metukuru (Jira)
Renuka Metukuru created KAFKA-8830: -- Summary: KIP-512: Adding headers to RecordMetaData Key: KAFKA-8830 URL: https://issues.apache.org/jira/browse/KAFKA-8830 Project: Kafka Issue Type: New F

[jira] [Commented] (KAFKA-8076) Flaky Test ProduceRequestTest#testSimpleProduceRequest

2019-08-23 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914536#comment-16914536 ] Sophie Blee-Goldman commented on KAFKA-8076: [https://builds.apache.org/job/k

[jira] [Commented] (KAFKA-8825) Add option to reset consumer offset by relative time

2019-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914334#comment-16914334 ] Sönke Liebau commented on KAFKA-8825: - I think that might also help in DR / failover

[jira] [Comment Edited] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers

2019-08-23 Thread Suri Nuthalapati (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914314#comment-16914314 ] Suri Nuthalapati edited comment on KAFKA-4674 at 8/23/19 2:56 PM: -

[jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers

2019-08-23 Thread Suri babu Nuthalapati (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914314#comment-16914314 ] Suri babu Nuthalapati commented on KAFKA-4674: -- Is there any ETA for the res

[jira] [Updated] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-23 Thread Marcos Passos (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marcos Passos updated KAFKA-8828: - Description: Since 2.3, {{ProcessorContext}} returns a  {{TimestampedKeyValueStore}} for global st

[jira] [Created] (KAFKA-8829) Provide factories for creating Window instances

2019-08-23 Thread Marcos Passos (Jira)
Marcos Passos created KAFKA-8829: Summary: Provide factories for creating Window instances Key: KAFKA-8829 URL: https://issues.apache.org/jira/browse/KAFKA-8829 Project: Kafka Issue Type: New

[jira] [Updated] (KAFKA-8827) kafka brokers intermittent traffic

2019-08-23 Thread frid (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frid updated KAFKA-8827: Description: i have kafka cluster with version 0.10.2, 3 brokers an 3 zookeeper i try to generete 25 mb/sec to my

[jira] [Created] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

2019-08-23 Thread Marcos Passos (Jira)
Marcos Passos created KAFKA-8828: Summary: [BC Break] Global store returns a TimestampedKeyValueStore in 2.3 Key: KAFKA-8828 URL: https://issues.apache.org/jira/browse/KAFKA-8828 Project: Kafka

[jira] [Created] (KAFKA-8827) kafka followers intermittent traffic

2019-08-23 Thread frid (Jira)
frid created KAFKA-8827: --- Summary: kafka followers intermittent traffic Key: KAFKA-8827 URL: https://issues.apache.org/jira/browse/KAFKA-8827 Project: Kafka Issue Type: Bug Affects Versions: 0.10.2

[jira] [Commented] (KAFKA-8818) CreatePartitions Request protocol documentation

2019-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914260#comment-16914260 ] Fábio Silva commented on KAFKA-8818: [~asutosh_pandya] may you take a look on this >

[jira] [Updated] (KAFKA-8818) CreatePartitions Request protocol documentation

2019-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fábio Silva updated KAFKA-8818: --- Reviewer: Asutosh Pandya > CreatePartitions Request protocol documentation >

[jira] [Updated] (KAFKA-8818) CreatePartitions Request protocol documentation

2019-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fábio Silva updated KAFKA-8818: --- Reviewer: (was: Asutosh Pandya) > CreatePartitions Request protocol documentation > ---

[jira] [Resolved] (KAFKA-8698) ListOffsets Response protocol documentation

2019-08-23 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8698. -- Fix Version/s: 2.4.0 Resolution: Fixed > ListOffsets Response protocol documentation > -

[jira] [Commented] (KAFKA-8698) ListOffsets Response protocol documentation

2019-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914254#comment-16914254 ] ASF GitHub Bot commented on KAFKA-8698: --- omkreddy commented on pull request #7141:

[jira] [Assigned] (KAFKA-8768) Replace DeleteRecords request/response with automated protocol

2019-08-23 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-8768: - Assignee: Mickael Maison > Replace DeleteRecords request/response with automated protoco

[jira] [Assigned] (KAFKA-8768) Replace DeleteRecords request/response with automated protocol

2019-08-23 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-8768: - Assignee: (was: Mickael Maison) > Replace DeleteRecords request/response with automa

[jira] [Updated] (KAFKA-6181) Examining log messages with {{--deep-iteration}} should show superset of fields

2019-08-23 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-6181: - Description: Printing log data on Kafka brokers using {{kafka.tools.DumpLogSegments}}: {