[jira] [Created] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

Stanislav Kozlovski created KAFKA-8406: -- Summary: kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config Key: KAFKA-8406 URL: https://issues.apache.org/jira/browse/KAF

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845782#comment-16845782 ] Matthias J. Sax commented on KAFKA-7245: Well. First we need a KIP to deprecate t

[jira] [Commented] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845824#comment-16845824 ] Sebastiaan commented on KAFKA-7678: --- Hi guys! I think this fix is not complete yet. In

[jira] [Comment Edited] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845824#comment-16845824 ] Sebastiaan edited comment on KAFKA-7678 at 5/22/19 12:16 PM: -

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845839#comment-16845839 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax], can you please elaborate on the issu

[jira] [Commented] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

[ https://issues.apache.org/jira/browse/KAFKA-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845963#comment-16845963 ] ASF GitHub Bot commented on KAFKA-8399: --- bbejeck commented on pull request #6779: K

[jira] [Resolved] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

[ https://issues.apache.org/jira/browse/KAFKA-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8399. Resolution: Fixed > Add back `internal.leave.group.on.close` config for KStreams >

[jira] [Created] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class'

Chris Egerton created KAFKA-8407: Summary: Connector client overrides broken on client configs with type 'Class' Key: KAFKA-8407 URL: https://issues.apache.org/jira/browse/KAFKA-8407 Project: Kafka

[jira] [Updated] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class'

[ https://issues.apache.org/jira/browse/KAFKA-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-8407: - Labels: connect (was: ) > Connector client overrides broken on client configs with type 'Class'

[jira] [Updated] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class' or 'List'

[ https://issues.apache.org/jira/browse/KAFKA-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-8407: - Description: When a connector request is submitted that overrides a client configuration that is

[jira] [Assigned] (KAFKA-8400) Do not update follower replica state if the log read failed

[ https://issues.apache.org/jira/browse/KAFKA-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-8400: -- Assignee: Jason Gustafson > Do not update follower replica state if the log read faile

[jira] [Commented] (KAFKA-8407) Connector client overrides broken on client configs with type 'Class' or 'List'

[ https://issues.apache.org/jira/browse/KAFKA-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846152#comment-16846152 ] ASF GitHub Bot commented on KAFKA-8407: --- C0urante commented on pull request #6789:

[jira] [Created] (KAFKA-8408) Create one request purgator for all the controller requests

Jose Armando Garcia Sancio created KAFKA-8408: - Summary: Create one request purgator for all the controller requests Key: KAFKA-8408 URL: https://issues.apache.org/jira/browse/KAFKA-8408 P

[jira] [Commented] (KAFKA-8408) Create one request purgator for all the controller requests

[ https://issues.apache.org/jira/browse/KAFKA-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846157#comment-16846157 ] Jose Armando Garcia Sancio commented on KAFKA-8408: --- What do you think

[jira] [Created] (KAFKA-8409) Seperate controller thread/manager events from controller events

Jose Armando Garcia Sancio created KAFKA-8409: - Summary: Seperate controller thread/manager events from controller events Key: KAFKA-8409 URL: https://issues.apache.org/jira/browse/KAFKA-8409

[jira] [Commented] (KAFKA-8219) Add web documentation for static membership

[ https://issues.apache.org/jira/browse/KAFKA-8219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846199#comment-16846199 ] ASF GitHub Bot commented on KAFKA-8219: --- abbccdda commented on pull request #6790:

[jira] [Commented] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846202#comment-16846202 ] John Roesler commented on KAFKA-8396: - Thanks [~guozhang]. Agreed. I've recently had

[jira] [Created] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

John Roesler created KAFKA-8410: --- Summary: Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well Key: KAFKA-8410 URL: https://issues.apache.org/jira/browse/KAFKA-8410 Projec

[jira] [Commented] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846206#comment-16846206 ] John Roesler commented on KAFKA-8396: - Created: https://issues.apache.org/jira/browse

[jira] [Commented] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846261#comment-16846261 ] Guozhang Wang commented on KAFKA-8410: -- [~vvcephei] Thanks for creating this ticket.

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846263#comment-16846263 ] SuryaTeja Duggi commented on KAFKA-7995: [~bchen225242] Can i pick this up I am n

[jira] [Resolved] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

[ https://issues.apache.org/jira/browse/KAFKA-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8389. -- Resolution: Won't Fix > Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverT

[jira] [Commented] (KAFKA-8402) bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB

[ https://issues.apache.org/jira/browse/KAFKA-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846315#comment-16846315 ] huxihx commented on KAFKA-8402: ---  A possible solution is to throw an exception when the len

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846356#comment-16846356 ] WooYoung commented on KAFKA-8311: - [~bchen225242] , I have written merge request message

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846402#comment-16846402 ] Omkar Mestry commented on KAFKA-7245: - Jira :- https://issues.apache.org/jira/browse/

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846416#comment-16846416 ] Matthias J. Sax commented on KAFKA-7245: All public API changes need a KIP. Hence

[jira] [Commented] (KAFKA-7928) Deprecate WindowStore.put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846417#comment-16846417 ] Matthias J. Sax commented on KAFKA-7928: This sees to be a duplicate of https://i

[jira] [Commented] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

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