[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695627#comment-16695627 ] Boyang Chen commented on KAFKA-7610: [~guozhang] [~hachikuji] Do you have any concern on 2)

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695566#comment-16695566 ] Mark Tranter commented on KAFKA-7653: - Some type of auto-config would be ideal. But I'm not sure how

[jira] [Commented] (KAFKA-1704) Add PartitionConfig besides LogConfig

[ https://issues.apache.org/jira/browse/KAFKA-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695557#comment-16695557 ] Srinivas Reddy commented on KAFKA-1704: --- Hi [~goyal.arpit.91], Thanks for the interest, please

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695446#comment-16695446 ] Matthias J. Sax commented on KAFKA-7653: I want to share another thought about this (brought up

[jira] [Updated] (KAFKA-7665) Replace BaseConsumerRecord with ConsumerRecord in MM

[ https://issues.apache.org/jira/browse/KAFKA-7665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-7665: -- Labels: needs-kip (was: ) > Replace BaseConsumerRecord with ConsumerRecord in MM >

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695375#comment-16695375 ] ASF GitHub Bot commented on KAFKA-7653: --- mtranter opened a new pull request #5938: KAFKA-7653 [WIP]

[jira] [Comment Edited] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695312#comment-16695312 ] Mark Tranter edited comment on KAFKA-7653 at 11/21/18 11:43 PM: Thats

[jira] [Commented] (KAFKA-7162) Flaky unit tests caused by record creation timestamps differ from validation time by more than timestampDiffMaxMs

[ https://issues.apache.org/jira/browse/KAFKA-7162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695335#comment-16695335 ] ASF GitHub Bot commented on KAFKA-7162: --- gitlw closed pull request #5367: KAFKA-7162: Fixing flaky

[jira] [Resolved] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5110. Resolution: Won't Fix Closing this as "won't fix" for now. The consumer group command no

[jira] [Resolved] (KAFKA-7428) ConnectionStressSpec: add "action", allow multiple clients

[ https://issues.apache.org/jira/browse/KAFKA-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7428. Resolution: Fixed > ConnectionStressSpec: add "action", allow multiple clients >

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695320#comment-16695320 ] ASF GitHub Bot commented on KAFKA-5110: --- hachikuji closed pull request #2892: KAFKA-5110: Check for

[jira] [Resolved] (KAFKA-5775) Implement Fault Injection testing for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-5775. Resolution: Fixed > Implement Fault Injection testing for Kafka >

[jira] [Commented] (KAFKA-6372) Trogdor should use LogContext for log messages

[ https://issues.apache.org/jira/browse/KAFKA-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695313#comment-16695313 ] Colin P. McCabe commented on KAFKA-6372: We do use LogContext in a few places now in Trogdor. We

[jira] [Resolved] (KAFKA-6372) Trogdor should use LogContext for log messages

[ https://issues.apache.org/jira/browse/KAFKA-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6372. Resolution: Fixed > Trogdor should use LogContext for log messages >

[jira] [Updated] (KAFKA-6372) Trogdor should use LogContext for log messages

[ https://issues.apache.org/jira/browse/KAFKA-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-6372: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-5775) > Trogdor

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695312#comment-16695312 ] Mark Tranter commented on KAFKA-7653: - Thats great guys thanks. I'll submit a WIP PR shortly to

[jira] [Resolved] (KAFKA-6352) Delay message down-conversion until response is ready to be sent

[ https://issues.apache.org/jira/browse/KAFKA-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6352. Resolution: Not A Problem This was addressed by

[jira] [Resolved] (KAFKA-7183) Add a trogdor test that creates many connections to brokers

[ https://issues.apache.org/jira/browse/KAFKA-7183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7183. Resolution: Fixed > Add a trogdor test that creates many connections to brokers >

[jira] [Resolved] (KAFKA-6785) Add Trogdor documentation

[ https://issues.apache.org/jira/browse/KAFKA-6785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6785. Resolution: Fixed > Add Trogdor documentation > - > >

[jira] [Resolved] (KAFKA-6696) Trogdor should support destroying tasks

[ https://issues.apache.org/jira/browse/KAFKA-6696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6696. Resolution: Fixed > Trogdor should support destroying tasks >

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695306#comment-16695306 ] Jason Gustafson edited comment on KAFKA-7610 at 11/21/18 10:18 PM: --- It

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695306#comment-16695306 ] Jason Gustafson commented on KAFKA-7610: It turns out the disconnect option is a bit limited.

[jira] [Resolved] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7231. Resolution: Fixed Fix Version/s: 2.0.1 2.1.0 >

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695268#comment-16695268 ] Guozhang Wang commented on KAFKA-7531: -- [~hachikuji] could you share your PR for exposing more logs

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695265#comment-16695265 ] Guozhang Wang commented on KAFKA-7504: -- [~allenxwang] The key idea of the current patch tries to

[jira] [Comment Edited] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695199#comment-16695199 ] Bruno Bieth edited comment on KAFKA-7654 at 11/21/18 8:35 PM: -- [~mjsax]

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695199#comment-16695199 ] Bruno Bieth commented on KAFKA-7654: [~mjsax] Thanks, I might end up writing a KIP if there is some

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7657: - Priority: Major (was: Minor) > Invalid reporting of stream state in Kafka streams application >

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695186#comment-16695186 ] Guozhang Wang commented on KAFKA-7657: -- Hi [~tscrowley] Thanks for reporting this issue. The

[jira] [Updated] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7657: - Labels: bug (was: ) > Invalid reporting of stream state in Kafka streams application >

[jira] [Assigned] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6585: Assignee: Samuel Hawker (was: Aditya Vivek) > Consolidate duplicated logic on reset

[jira] [Commented] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695108#comment-16695108 ] Guozhang Wang commented on KAFKA-6585: -- [~Samuel Hawker] you can find the consumer reset tool in

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695054#comment-16695054 ] Guozhang Wang commented on KAFKA-7654: -- [~backuitist] [~mjsax] There seems to have several

[jira] [Commented] (KAFKA-7666) KIP-391: Allow Producing with Offsets for Cluster Replication

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

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694960#comment-16694960 ] Matthias J. Sax commented on KAFKA-7654: Thanks for sharing your thoughts. This are all valid

[jira] [Created] (KAFKA-7666) KIP-391: Allow Producing with Offsets for Cluster Replication

Edoardo Comar created KAFKA-7666: Summary: KIP-391: Allow Producing with Offsets for Cluster Replication Key: KAFKA-7666 URL: https://issues.apache.org/jira/browse/KAFKA-7666 Project: Kafka

[jira] [Assigned] (KAFKA-7390) Enable the find-sec-bugs spotBugs plugin for Gradle

[ https://issues.apache.org/jira/browse/KAFKA-7390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Nguyen reassigned KAFKA-7390: - Assignee: Tim Nguyen > Enable the find-sec-bugs spotBugs plugin for Gradle >

[jira] [Comment Edited] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694768#comment-16694768 ] xiaojing zhou edited comment on KAFKA-3686 at 11/21/18 2:27 PM: I have

[jira] [Comment Edited] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694768#comment-16694768 ] xiaojing zhou edited comment on KAFKA-3686 at 11/21/18 2:26 PM: I have

[jira] [Commented] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694768#comment-16694768 ] xiaojing zhou commented on KAFKA-3686: -- I have the same issue with version 1.0.1. The send request

[jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods.

[ https://issues.apache.org/jira/browse/KAFKA-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694474#comment-16694474 ] Bruno Bieth commented on KAFKA-7654: bq. It a Java limitation that we loose type safety for default

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694382#comment-16694382 ] Michael Noll commented on KAFKA-7653: - For [~mark.tranter]: If this change does require a KIP (Kafka