[jira] [Created] (KAFKA-9433) Replace AlterConfigs request/response with automated protocol

Tom Bentley created KAFKA-9433: -- Summary: Replace AlterConfigs request/response with automated protocol Key: KAFKA-9433 URL: https://issues.apache.org/jira/browse/KAFKA-9433 Project: Kafka Issu

[jira] [Created] (KAFKA-9432) Replace DescribeConfigs request/response with automated protocol

Tom Bentley created KAFKA-9432: -- Summary: Replace DescribeConfigs request/response with automated protocol Key: KAFKA-9432 URL: https://issues.apache.org/jira/browse/KAFKA-9432 Project: Kafka I

[jira] [Created] (KAFKA-9434) Replace AlterReplicaLogDirs request/response with automated protocol

Tom Bentley created KAFKA-9434: -- Summary: Replace AlterReplicaLogDirs request/response with automated protocol Key: KAFKA-9434 URL: https://issues.apache.org/jira/browse/KAFKA-9434 Project: Kafka

[jira] [Created] (KAFKA-9435) Replace DescribeLogDirs request/response with automated protocol

Tom Bentley created KAFKA-9435: -- Summary: Replace DescribeLogDirs request/response with automated protocol Key: KAFKA-9435 URL: https://issues.apache.org/jira/browse/KAFKA-9435 Project: Kafka I

[jira] [Created] (KAFKA-9436) New Kafka Connect SMT for plainText => Struct(or Map)

whsoul created KAFKA-9436: - Summary: New Kafka Connect SMT for plainText => Struct(or Map) Key: KAFKA-9436 URL: https://issues.apache.org/jira/browse/KAFKA-9436 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9436) New Kafka Connect SMT for plainText => Struct(or Map)

[ https://issues.apache.org/jira/browse/KAFKA-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015833#comment-17015833 ] whsoul commented on KAFKA-9436: --- [https://github.com/apache/kafka/pull/7965] > New Kafka C

[jira] [Issue Comment Deleted] (KAFKA-9436) New Kafka Connect SMT for plainText => Struct(or Map)

[ https://issues.apache.org/jira/browse/KAFKA-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] whsoul updated KAFKA-9436: -- Comment: was deleted (was: [https://github.com/apache/kafka/pull/7965]) > New Kafka Connect SMT for plainText

[jira] [Created] (KAFKA-9437) KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

David Jacot created KAFKA-9437: -- Summary: KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies Key: KAFKA-9437 URL: https://issues.apache.org/jira/browse/KAFKA-9437 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9414) sink-task-metrics.sink-record-lag-max metric is not exposed

[ https://issues.apache.org/jira/browse/KAFKA-9414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aidar Makhmutov resolved KAFKA-9414. Resolution: Not A Bug It's not been implemented yet. > sink-task-metrics.sink-record-lag-m

[jira] [Assigned] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov reassigned KAFKA-9323: -- Assignee: Nikolay Izhikov > Refactor Streams' upgrade system tests >

[jira] [Commented] (KAFKA-8847) Deprecate and remove usage of supporting classes in kafka.security.auth

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

[jira] [Commented] (KAFKA-9428) Expose standby information in KafkaStreams via queryMetadataForKey API

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

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016128#comment-17016128 ] Raman Gupta commented on KAFKA-8803: This happened to me again today. Recycling 3 of

[jira] [Created] (KAFKA-9438) Issue with mm2 active/active replication

Roman created KAFKA-9438: Summary: Issue with mm2 active/active replication Key: KAFKA-9438 URL: https://issues.apache.org/jira/browse/KAFKA-9438 Project: Kafka Issue Type: Bug Components:

[jira] [Updated] (KAFKA-9438) Issue with mm2 active/active replication

[ https://issues.apache.org/jira/browse/KAFKA-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman updated KAFKA-9438: - Description: Hi,   i am trying to configure the the active/active with new kafka 2.4.0 and MM2. I have 2 kafka

[jira] [Commented] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016167#comment-17016167 ] Nikolay Izhikov commented on KAFKA-9323: Hello, [~ableegoldman] Can you, please,

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016236#comment-17016236 ] Raman Gupta commented on KAFKA-8803: Looks like this is not just a dev-ops issue, fro

[jira] [Created] (KAFKA-9439) Add more public API tests for KafkaProducer

Boyang Chen created KAFKA-9439: -- Summary: Add more public API tests for KafkaProducer Key: KAFKA-9439 URL: https://issues.apache.org/jira/browse/KAFKA-9439 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys

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

[jira] [Created] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

Boyang Chen created KAFKA-9440: -- Summary: Add ConsumerGroupCommand to delete static members Key: KAFKA-9440 URL: https://issues.apache.org/jira/browse/KAFKA-9440 Project: Kafka Issue Type: Impro

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016294#comment-17016294 ] Sophie Blee-Goldman commented on KAFKA-7591: Right, that is why I say if we c

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016296#comment-17016296 ] Sophie Blee-Goldman commented on KAFKA-3596: [~vvcephei] Can we close this? I

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016306#comment-17016306 ] Sophie Blee-Goldman commented on KAFKA-6629: Unassigned since there has been

[jira] [Assigned] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-6629: -- Assignee: (was: Manasvi Gupta) > SegmentedCacheFunctionTest does not cover

[jira] [Commented] (KAFKA-9358) Explicitly resign controller leadership and broker znode

[ https://issues.apache.org/jira/browse/KAFKA-9358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016325#comment-17016325 ] ASF GitHub Bot commented on KAFKA-9358: --- mumrah commented on pull request #7968: KA

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016352#comment-17016352 ] Matthias J. Sax commented on KAFKA-7591: Personally, I don't see why updating the

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016358#comment-17016358 ] Matthias J. Sax commented on KAFKA-3596: I don't think that the behavior changed

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016366#comment-17016366 ] Sophie Blee-Goldman commented on KAFKA-3596: I see, maybe I misunderstood the

[jira] [Resolved] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-3596. Resolution: Not A Problem > Kafka Streams: Window expiration needs to consider more

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016372#comment-17016372 ] Sophie Blee-Goldman commented on KAFKA-7591: That's fair, I suppose if it _wa

[jira] [Assigned] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9441: -- Assignee: Matthias J. Sax > Refactor commit logic > - > >

[jira] [Created] (KAFKA-9441) Refactor commit logic

Matthias J. Sax created KAFKA-9441: -- Summary: Refactor commit logic Key: KAFKA-9441 URL: https://issues.apache.org/jira/browse/KAFKA-9441 Project: Kafka Issue Type: Sub-task Compon

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016395#comment-17016395 ] Matthias J. Sax commented on KAFKA-7591: SGTM. > Changelog retention period does

[jira] [Created] (KAFKA-9442) Kafka connect REST API times out when trying to create a connector

Kedar Shenoy created KAFKA-9442: --- Summary: Kafka connect REST API times out when trying to create a connector Key: KAFKA-9442 URL: https://issues.apache.org/jira/browse/KAFKA-9442 Project: Kafka

[jira] [Updated] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9323: --- Description: With the introduction of version probing in 2.0 and cooperative rebalanc

[jira] [Commented] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016420#comment-17016420 ] Sophie Blee-Goldman commented on KAFKA-9323: Hey [~nizhikov], thanks for pick

[jira] [Comment Edited] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016420#comment-17016420 ] Sophie Blee-Goldman edited comment on KAFKA-9323 at 1/16/20 12:58 AM: -

[jira] [Commented] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016438#comment-17016438 ] Sophie Blee-Goldman commented on KAFKA-9323: I can help you figure out the up

[jira] [Commented] (KAFKA-9439) Add more public API tests for KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016479#comment-17016479 ] Xiang Zhang commented on KAFKA-9439: I am interested in this, as a newbie, could I ge

[jira] [Assigned] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

[ https://issues.apache.org/jira/browse/KAFKA-9338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9338: -- Assignee: Jason Gustafson > Incremental fetch sessions do not maintain or use leader e

[jira] [Commented] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

[ https://issues.apache.org/jira/browse/KAFKA-9338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016488#comment-17016488 ] Jason Gustafson commented on KAFKA-9338: [~lucasbradstreet] Thanks, good find. >

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016489#comment-17016489 ] John Roesler commented on KAFKA-9259: - Yep! That sounds right. > suppress() for wind

[jira] [Commented] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

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

[jira] [Resolved] (KAFKA-9410) Make groupId Optional in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9410. Resolution: Fixed > Make groupId Optional in KafkaConsumer > --

[jira] [Commented] (KAFKA-9410) Make groupId Optional in KafkaConsumer

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

[jira] [Commented] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

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