[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&focusedCommentId=16694382#comment-16694382 ] Michael Noll commented on KAFKA-7653: - For [~mark.tranter]: If this change does requi

[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&focusedCommentId=16694474#comment-16694474 ] Bruno Bieth commented on KAFKA-7654: bq. It a Java limitation that we loose type safe

[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&focusedCommentId=16694768#comment-16694768 ] xiaojing zhou commented on KAFKA-3686: -- I have the same issue with version 1.0.1. T

[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&focusedCommentId=16694768#comment-16694768 ] xiaojing zhou edited comment on KAFKA-3686 at 11/21/18 2:26 PM: ---

[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&focusedCommentId=16694768#comment-16694768 ] xiaojing zhou edited comment on KAFKA-3686 at 11/21/18 2:27 PM: ---

[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] [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] [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&focusedCommentId=16694960#comment-16694960 ] Matthias J. Sax commented on KAFKA-7654: Thanks for sharing your thoughts. This a

[jira] [Assigned] (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:all-tabpanel ] Edoardo Comar reassigned KAFKA-7666: Assignee: Edoardo Comar Description: Implementing KIP-391 https://cwiki.apache.org/

[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&focusedCommentId=16694975#comment-16694975 ] ASF GitHub Bot commented on KAFKA-7666: --- edoardocomar opened a new pull request #59

[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&focusedCommentId=16695054#comment-16695054 ] Guozhang Wang commented on KAFKA-7654: -- [~backuitist] [~mjsax] There seems to have s

[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 tools

[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&focusedCommentId=16695108#comment-16695108 ] Guozhang Wang commented on KAFKA-6585: -- [~Samuel Hawker] you can find the consumer r

[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] [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&focusedCommentId=16695186#comment-16695186 ] Guozhang Wang commented on KAFKA-7657: -- Hi [~tscrowley] Thanks for reporting this is

[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-7654) Relax requirements on serializing-only methods.

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

[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&focusedCommentId=16695199#comment-16695199 ] Bruno Bieth edited comment on KAFKA-7654 at 11/21/18 8:35 PM: -

[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&focusedCommentId=16695265#comment-16695265 ] Guozhang Wang commented on KAFKA-7504: -- [~allenxwang] The key idea of the current pa

[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&focusedCommentId=16695268#comment-16695268 ] Guozhang Wang commented on KAFKA-7531: -- [~hachikuji] could you share your PR for exp

[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 > NetworkClient.newC

[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&focusedCommentId=16695306#comment-16695306 ] Jason Gustafson edited comment on KAFKA-7610 at 11/21/18 10:18 PM:

[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&focusedCommentId=16695306#comment-16695306 ] Jason Gustafson commented on KAFKA-7610: It turns out the disconnect option is a

[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] [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-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 [KIP-283|https://cwiki.apache.org/confluen

[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] [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&focusedCommentId=16695312#comment-16695312 ] Mark Tranter commented on KAFKA-7653: - Thats great guys thanks. I'll submit a WIP P

[jira] [Updated] (KAFKA-5791) Add HTTPS support to the fault injector

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

[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 shou

[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] [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&focusedCommentId=16695313#comment-16695313 ] Colin P. McCabe commented on KAFKA-6372: We do use LogContext in a few places now

[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-5110) ConsumerGroupCommand error handling improvement

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

[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] [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 lo

[jira] [Resolved] (KAFKA-2931) Consumer rolling upgrade test case

[ https://issues.apache.org/jira/browse/KAFKA-2931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2931. Resolution: Fixed This was resolved by https://github.com/apache/kafka/pull/619. > Consume

[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&focusedCommentId=16695335#comment-16695335 ] ASF GitHub Bot commented on KAFKA-7162: --- gitlw closed pull request #5367: KAFKA-716

[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&focusedCommentId=16695312#comment-16695312 ] Mark Tranter edited comment on KAFKA-7653 at 11/21/18 11:43 PM: ---

[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&focusedCommentId=16695375#comment-16695375 ] ASF GitHub Bot commented on KAFKA-7653: --- mtranter opened a new pull request #5938:

[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&focusedCommentId=16695446#comment-16695446 ] Matthias J. Sax commented on KAFKA-7653: I want to share another thought about th

[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&focusedCommentId=16695557#comment-16695557 ] Srinivas Reddy commented on KAFKA-1704: --- Hi [~goyal.arpit.91], Thanks for the inte

[jira] [Commented] (KAFKA-1548) Refactor the "replica_id" in requests

[ https://issues.apache.org/jira/browse/KAFKA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1669#comment-1669 ] Srinivas Reddy commented on KAFKA-1548: --- The PR for this task is closed. Does this

[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&focusedCommentId=16695566#comment-16695566 ] Mark Tranter commented on KAFKA-7653: - Some type of auto-config would be ideal. But

[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&focusedCommentId=16695627#comment-16695627 ] Boyang Chen commented on KAFKA-7610: [~guozhang] [~hachikuji] Do you have any concern