[jira] [Updated] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5975: --- Fix Version/s: (was: 1.0.2) > No response when deleting topics and delete.topic.enable=fa

[jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4950: --- Fix Version/s: (was: 1.0.2) > ConcurrentModificationException when iterating over Kafka M

[jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5973: --- Fix Version/s: (was: 1.0.2) > ShutdownableThread catching errors can lead to partial hard

[jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods

[ https://issues.apache.org/jira/browse/KAFKA-5445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5445: --- Fix Version/s: (was: 1.0.2) > Document exceptions thrown by AdminClient methods > ---

[jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker

[ https://issues.apache.org/jira/browse/KAFKA-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4686: --- Fix Version/s: (was: 1.0.2) > Null Message payload is shutting down broker >

[jira] [Updated] (KAFKA-6083) The Fetcher should add the InvalidRecordException as a cause to the KafkaException when invalid record is found.

[ https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6083: --- Fix Version/s: (was: 1.0.2) > The Fetcher should add the InvalidRecordException as a caus

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4972: --- Fix Version/s: (was: 1.0.2) > Kafka 0.10.0 Found a corrupted index file during Kafka bro

[jira] [Updated] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5474: --- Affects Version/s: (was: 1.0.0) 0.11.0.0 > Streams StandbyTask sho

[jira] [Updated] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5474: --- Fix Version/s: 0.11.0.1 1.0.0 > Streams StandbyTask should no checkpoint o

[jira] [Resolved] (KAFKA-6445) Remove deprecated metrics in 2.0

[ https://issues.apache.org/jira/browse/KAFKA-6445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6445. Resolution: Fixed Assignee: Dong Lin (was: Charly Molter) Fix Version/s: (was:

[jira] [Commented] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513367#comment-16513367 ] Ismael Juma commented on KAFKA-5950: [~cmccabe], this has been done right? > AdminCl

[jira] [Commented] (KAFKA-7021) Source KTable checkpoint is not correct

[ https://issues.apache.org/jira/browse/KAFKA-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513358#comment-16513358 ] ASF GitHub Bot commented on KAFKA-7021: --- guozhangwang closed pull request #5232: KA

[jira] [Updated] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6360: --- Fix Version/s: 1.0.2 0.11.0.3 0.10.2.2 > RocksDB segmen

[jira] [Updated] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6360: --- Affects Version/s: 0.10.2.1 0.11.0.2 1.0.1 > Ro

[jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513317#comment-16513317 ] ASF GitHub Bot commented on KAFKA-6975: --- apovzner opened a new pull request #5235:

[jira] [Resolved] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7055. Resolution: Fixed Fix Version/s: 2.0.0 > Kafka Streams Processor API allows you to a

[jira] [Commented] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513283#comment-16513283 ] ASF GitHub Bot commented on KAFKA-7055: --- mjsax closed pull request #5215: KAFKA-705

[jira] [Commented] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties

[ https://issues.apache.org/jira/browse/KAFKA-7060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513158#comment-16513158 ] ASF GitHub Bot commented on KAFKA-7060: --- kevin-laff opened a new pull request #5234

[jira] [Updated] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6975: --- Fix Version/s: 1.1.1 > AdminClient.deleteRecords() may cause replicas unable to fetch from be

[jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513135#comment-16513135 ] Matthias J. Sax commented on KAFKA-5054: There was a PR that got merged IMHO. I t

[jira] [Created] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties

Kevin Lafferty created KAFKA-7060: - Summary: Command-line overrides for ConnectDistributed worker properties Key: KAFKA-7060 URL: https://issues.apache.org/jira/browse/KAFKA-7060 Project: Kafka

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513124#comment-16513124 ] ASF GitHub Bot commented on KAFKA-6711: --- mjsax closed pull request #4782: KAFKA-671

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513125#comment-16513125 ] ASF GitHub Bot commented on KAFKA-6711: --- mjsax closed pull request #4789: KAFKA-671

[jira] [Assigned] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Al-Mehdi reassigned KAFKA-5098: - Assignee: Ahmed Al-Mehdi (was: huxihx) > KafkaProducer.send() blocks and generates Time

[jira] [Updated] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6711: --- Fix Version/s: 1.1.1 1.0.2 0.11.0.3 0

[jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513059#comment-16513059 ] Ahmed Al-Mehdi commented on KAFKA-5098: --- Since there was no response from the curre

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513045#comment-16513045 ] Ted Yu commented on KAFKA-7012: --- bq. not treating this case at all and suffering the (rare?

[jira] [Comment Edited] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513037#comment-16513037 ] radai rosenblatt edited comment on KAFKA-7012 at 6/14/18 9:46 PM: -

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513037#comment-16513037 ] radai rosenblatt commented on KAFKA-7012: - i dont have the time to pick this up r

[jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

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

[jira] [Commented] (KAFKA-7021) Source KTable checkpoint is not correct

[ https://issues.apache.org/jira/browse/KAFKA-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513013#comment-16513013 ] ASF GitHub Bot commented on KAFKA-7021: --- guozhangwang opened a new pull request #52

[jira] [Resolved] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH

[ https://issues.apache.org/jira/browse/KAFKA-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7010. Resolution: Fixed merged the PR to trunk and 2.0 branch. > Rename ResourceNameType.ANY to MATCH >

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512935#comment-16512935 ] rajadayalan perumalsamy commented on KAFKA-7012: Thanks, are you planning

[jira] [Commented] (KAFKA-6583) Metadata should include number of state stores for task

[ https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512881#comment-16512881 ] Matthias J. Sax commented on KAFKA-6583: Yes. KIP-268 is done. > Metadata should

[jira] [Commented] (KAFKA-2983) Remove old Scala consumer and all related code, tests, and tools

[ https://issues.apache.org/jira/browse/KAFKA-2983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512864#comment-16512864 ] ASF GitHub Bot commented on KAFKA-2983: --- ijuma opened a new pull request #5230: KAF

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512826#comment-16512826 ] wade wu commented on KAFKA-6982: You can manually add that line of code and build Kafka.

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512824#comment-16512824 ] Manikumar commented on KAFKA-6982: -- This is a minor issue. Only occurs for a brief perio

[jira] [Resolved] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2837. Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 2.0.0 This test has

[jira] [Comment Edited] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512810#comment-16512810 ] Martin M edited comment on KAFKA-6982 at 6/14/18 5:42 PM: -- Thank

[jira] [Commented] (KAFKA-7021) Source KTable checkpoint is not correct

[ https://issues.apache.org/jira/browse/KAFKA-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512813#comment-16512813 ] ASF GitHub Bot commented on KAFKA-7021: --- guozhangwang closed pull request #5207: KA

[jira] [Assigned] (KAFKA-4237) Avoid long request timeout for the consumer

[ https://issues.apache.org/jira/browse/KAFKA-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4237: -- Assignee: Jason Gustafson > Avoid long request timeout for the consumer >

[jira] [Resolved] (KAFKA-4237) Avoid long request timeout for the consumer

[ https://issues.apache.org/jira/browse/KAFKA-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4237. Resolution: Duplicate Duplicate of KAFKA-7050. > Avoid long request timeout for the consumer > ---

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512810#comment-16512810 ] Martin M commented on KAFKA-6982: - Thanks [~omkreddy].  1.1.1 is not officially availabl

[jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512809#comment-16512809 ] ASF GitHub Bot commented on KAFKA-6975: --- apovzner opened a new pull request #5229:

[jira] [Comment Edited] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510295#comment-16510295 ] Eugen Feller edited comment on KAFKA-6977 at 6/14/18 5:38 PM: -

[jira] [Comment Edited] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510295#comment-16510295 ] Eugen Feller edited comment on KAFKA-6977 at 6/14/18 5:37 PM: -

[jira] [Updated] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-6982: - Fix Version/s: (was: 2.0.0) 1.1.1 java.lang.ArithmeticException was fixed in 1.1.1

[jira] [Comment Edited] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510295#comment-16510295 ] Eugen Feller edited comment on KAFKA-6977 at 6/14/18 5:18 PM: -

[jira] [Updated] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugen Feller updated KAFKA-6977: Description: We are running Kafka Streams 0.11.0.1 with Kafka Broker 0.10.2.1 and constantly run i

[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512758#comment-16512758 ] Martin M commented on KAFKA-6982: - How can we get a patch for 1.1.0? Thanks  > java.lan

[jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512722#comment-16512722 ] Richard Yu commented on KAFKA-4696: --- Hi, I will probably restart my work on this. > St

[jira] [Resolved] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6975. Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.0.2)

[jira] [Commented] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512623#comment-16512623 ] Rajini Sivaram commented on KAFKA-6806: --- Thanks [~rhauch] > Unable to validate sin

[jira] [Commented] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512618#comment-16512618 ] Gunnar Morling commented on KAFKA-7058: --- Thanks for the quick review, [~rhauch]. It

[jira] [Commented] (KAFKA-6583) Metadata should include number of state stores for task

[ https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512615#comment-16512615 ] Richard Yu commented on KAFKA-6583: --- [~mjsax] Did you finish the upgrade path for metad

[jira] [Comment Edited] (KAFKA-6583) Metadata should include number of state stores for task

[ https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512615#comment-16512615 ] Richard Yu edited comment on KAFKA-6583 at 6/14/18 3:31 PM: [

[jira] [Commented] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

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

[jira] [Commented] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512606#comment-16512606 ] Randall Hauch commented on KAFKA-7058: -- [~gunnar.morling] thanks for the PR. It look

[jira] [Updated] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7058: - Affects Version/s: 1.0.0 1.1.0 > ConnectSchema#equals() broken for array-t

[jira] [Comment Edited] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512586#comment-16512586 ] Randall Hauch edited comment on KAFKA-6806 at 6/14/18 3:10 PM:

[jira] [Updated] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6806: - Priority: Major (was: Blocker) Fix Version/s: (was: 1.1.1) (w

[jira] [Commented] (KAFKA-7059) Offer new constructor on ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512572#comment-16512572 ] ASF GitHub Bot commented on KAFKA-7059: --- matzew opened a new pull request #5228: KA

[jira] [Created] (KAFKA-7059) Offer new constructor on ProducerRecord

Matthias Weßendorf created KAFKA-7059: - Summary: Offer new constructor on ProducerRecord Key: KAFKA-7059 URL: https://issues.apache.org/jira/browse/KAFKA-7059 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magesh kumar Nandakumar updated KAFKA-7039: --- Priority: Blocker (was: Critical) > DelegatingClassLoader creates plugin ins

[jira] [Commented] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512493#comment-16512493 ] Magesh kumar Nandakumar commented on KAFKA-7039: [~rsivaram] I think this

[jira] [Updated] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magesh kumar Nandakumar updated KAFKA-7039: --- Fix Version/s: (was: 2.1.0) 2.0.0 > DelegatingClassLoa

[jira] [Resolved] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6711. --- Resolution: Fixed Reviewer: Matthias J. Sax Fix Version/s: 2.0.0 > GlobalStat

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512359#comment-16512359 ] ASF GitHub Bot commented on KAFKA-6711: --- rajinisivaram closed pull request #5219: K

[jira] [Commented] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512270#comment-16512270 ] ASF GitHub Bot commented on KAFKA-7058: --- gunnarmorling opened a new pull request #5

[jira] [Commented] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512266#comment-16512266 ] ASF GitHub Bot commented on KAFKA-7015: --- jadireddi opened a new pull request #5224:

[jira] [Updated] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-7058: -- Component/s: KafkaConnect > ConnectSchema#equals() broken for array-typed default values >

[jira] [Updated] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-7058: -- Description: {{ConnectSchema#equals()}} calls {{Objects#equals()}} for the schemas' default val

[jira] [Commented] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512261#comment-16512261 ] Gunnar Morling commented on KAFKA-7058: --- I'll send a pull request for this in a bit

[jira] [Created] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

Gunnar Morling created KAFKA-7058: - Summary: ConnectSchema#equals() broken for array-typed default values Key: KAFKA-7058 URL: https://issues.apache.org/jira/browse/KAFKA-7058 Project: Kafka

[jira] [Updated] (KAFKA-7057) Consumer stop polling

[ https://issues.apache.org/jira/browse/KAFKA-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moshe Lavi updated KAFKA-7057: -- Description: We build 3 Kafka brokers (0.10.1.1) version using Spring Cloud Stream consumer to poll me

[jira] [Created] (KAFKA-7057) Consumer stop polling

Moshe Lavi created KAFKA-7057: - Summary: Consumer stop polling Key: KAFKA-7057 URL: https://issues.apache.org/jira/browse/KAFKA-7057 Project: Kafka Issue Type: Bug Components: consumer,

[jira] [Resolved] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka

[ https://issues.apache.org/jira/browse/KAFKA-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4812. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

[jira] [Updated] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Majnarić updated KAFKA-6806: - Environment: CP4.1, Centos7 (was: CP4.1., Centos7) > Unable to validate sink connectors without

[jira] [Commented] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512145#comment-16512145 ] Ivan Majnarić commented on KAFKA-6806: -- Hi [~rsivaram] and [~lindong] [~rhauch] set

[jira] [Updated] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7039: -- Fix Version/s: (was: 2.0.0) 2.1.0 [~mageshn] Moving this out to 2.1.0 si

[jira] [Updated] (KAFKA-7028) super.users doesn't work with custom principals

[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7028: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since there i

[jira] [Updated] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required

[ https://issues.apache.org/jira/browse/KAFKA-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7045: -- Fix Version/s: (was: 2.0.0) 2.0.1 [~dhruvilshah] Moving this out to 2.0.

[jira] [Updated] (KAFKA-6805) Allow dynamic broker configs to be configured in ZooKeeper before starting broker

[ https://issues.apache.org/jira/browse/KAFKA-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6805: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid

[ https://issues.apache.org/jira/browse/KAFKA-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6697: -- Fix Version/s: (was: 2.0.0) 2.1.0 [~lindong] Moving this to 2.1.0 since

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6684: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Commented] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512110#comment-16512110 ] Rajini Sivaram commented on KAFKA-6806: --- Hi [~rhauch] [~iMajna] Same question as ab

[jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings

[ https://issues.apache.org/jira/browse/KAFKA-6342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6342: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7051: -- Fix Version/s: (was: 2.0.0) 2.1.0 [~cmccabe] Moving this out to 2.1.0 si

[jira] [Updated] (KAFKA-6897) Mirrormaker waits to shut down forever on produce failure with abort.on.send.failure=true

[ https://issues.apache.org/jira/browse/KAFKA-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6897: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all

[ https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6648: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods

[ https://issues.apache.org/jira/browse/KAFKA-5445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5445: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5098: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Updated] (KAFKA-6780) log cleaner shouldn't clean messages beyond high watermark

[ https://issues.apache.org/jira/browse/KAFKA-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6780: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since there i

[jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-4950: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out since it is not ready

[jira] [Updated] (KAFKA-5479) Docs for authorization omit authorizer.class.name

[ https://issues.apache.org/jira/browse/KAFKA-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5479: -- Fix Version/s: (was: 2.0.0) 2.1.0 Moving this out to 2.1.0 since it is n

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512051#comment-16512051 ] Don commented on KAFKA-4113: Hi Ben, you had a very interesting link in the original comment.