[jira] [Commented] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16571135#comment-16571135 ] Robert Yokota commented on KAFKA-7242: -- [~bsiamionau], thanks for finding and loggin

[jira] [Commented] (KAFKA-7253) The connector type responded by worker is always null when creating connector

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

[jira] [Assigned] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-5928: --- Assignee: Genmao Yu > Avoid redundant requests to zookeeper when reassign topic partition >

[jira] [Created] (KAFKA-7253) The connector type responded by worker is always null when creating connector

Chia-Ping Tsai created KAFKA-7253: - Summary: The connector type responded by worker is always null when creating connector Key: KAFKA-7253 URL: https://issues.apache.org/jira/browse/KAFKA-7253 Project

[jira] [Updated] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5928: Fix Version/s: 2.1.0 > Avoid redundant requests to zookeeper when reassign topic partition > --

[jira] [Commented] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

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

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570964#comment-16570964 ] Guozhang Wang commented on KAFKA-7250: -- Ack, thanks! > Kafka-Streams-Scala DSL tran

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

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

[jira] [Comment Edited] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570897#comment-16570897 ] Michal Dziemianko edited comment on KAFKA-7250 at 8/6/18 11:04 PM:

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570897#comment-16570897 ] Michal Dziemianko commented on KAFKA-7250: -- [~guozhang] it seems like the API is

[jira] [Assigned] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-7242: Assignee: Robert Yokota > Externalized secrets are revealed in task configuration > --

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

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

[jira] [Updated] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

[ https://issues.apache.org/jira/browse/KAFKA-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7252: --- Affects Version/s: (was: 0.11.0.0) > Default value for 'state.dir' is incorrect in the do

[jira] [Commented] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

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

[jira] [Commented] (KAFKA-7142) Rebalancing large consumer group can block the coordinator broker for several seconds

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

[jira] [Assigned] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

[ https://issues.apache.org/jira/browse/KAFKA-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7252: -- Assignee: Matthias J. Sax > Default value for 'state.dir' is incorrect in the docs > -

[jira] [Commented] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

[ https://issues.apache.org/jira/browse/KAFKA-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570669#comment-16570669 ] Matthias J. Sax commented on KAFKA-7252: I was just double checking and cannot fi

[jira] [Issue Comment Deleted] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

[ https://issues.apache.org/jira/browse/KAFKA-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7252: --- Comment: was deleted (was: Fixed in `trunk`, `2.0`, `1.1`, and `1.0` via  https://github.com/

[jira] [Commented] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

[ https://issues.apache.org/jira/browse/KAFKA-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570650#comment-16570650 ] Matthias J. Sax commented on KAFKA-7252: Fixed in `trunk`, `2.0`, `1.1`, and `1.0

[jira] [Updated] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7250: --- Labels: scala (was: ) > Kafka-Streams-Scala DSL transform shares transformer instance >

[jira] [Updated] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7250: --- Component/s: streams > Kafka-Streams-Scala DSL transform shares transformer instance > --

[jira] [Updated] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7250: --- Affects Version/s: 2.0.0 > Kafka-Streams-Scala DSL transform shares transformer instance > --

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570608#comment-16570608 ] Guozhang Wang commented on KAFKA-7250: -- Great! I've assigned you to the ticket, plea

[jira] [Assigned] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7250: Assignee: Michal Dziemianko (was: Michal) > Kafka-Streams-Scala DSL transform shares tran

[jira] [Assigned] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7250: Assignee: Michal > Kafka-Streams-Scala DSL transform shares transformer instance > ---

[jira] [Updated] (KAFKA-5071) ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.errors.ProcessorStateExcepti

[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5071: - Summary: ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-12

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570566#comment-16570566 ] Michal Dziemianko commented on KAFKA-7250: -- Absolutely, no problem > Kafka-S

[jira] [Created] (KAFKA-7252) Default value for 'state.dir' is incorrect in the docs

Brett Harper created KAFKA-7252: --- Summary: Default value for 'state.dir' is incorrect in the docs Key: KAFKA-7252 URL: https://issues.apache.org/jira/browse/KAFKA-7252 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570551#comment-16570551 ] Guozhang Wang commented on KAFKA-7250: -- [~michald] Do you want to submit a PR to fix

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570549#comment-16570549 ] Guozhang Wang commented on KAFKA-7250: -- I looked at the code and can confirm it is t

[jira] [Commented] (KAFKA-2423) Expand scalafmt coverage to core

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

[jira] [Created] (KAFKA-7251) Add support for TLS 1.3

Rajini Sivaram created KAFKA-7251: - Summary: Add support for TLS 1.3 Key: KAFKA-7251 URL: https://issues.apache.org/jira/browse/KAFKA-7251 Project: Kafka Issue Type: New Feature Com

[jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception

[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570436#comment-16570436 ] Biplob Biswas commented on KAFKA-5649: -- Same environment and same behaviour, did any

[jira] [Commented] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

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

[jira] [Commented] (KAFKA-7117) Allow AclCommand to use AdminClient API

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

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570381#comment-16570381 ] Chris Thunes commented on KAFKA-7165: - One option would be to put a retry mechanism a

[jira] [Updated] (KAFKA-7248) Kafka creating topic with no leader. Issue started showing up after unkerberizing the cluster

[ https://issues.apache.org/jira/browse/KAFKA-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7248: - Component/s: (was: KafkaConnect) core > Kafka creating topic with no leader.

[jira] [Commented] (KAFKA-7248) Kafka creating topic with no leader. Issue started showing up after unkerberizing the cluster

[ https://issues.apache.org/jira/browse/KAFKA-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570279#comment-16570279 ] Randall Hauch commented on KAFKA-7248: -- Removed {{Kafka Connect}} from the component

[jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers

[ https://issues.apache.org/jira/browse/KAFKA-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16570190#comment-16570190 ] Russ Brasser commented on KAFKA-4674: - Any update on this? We just ran into what seem

[jira] [Created] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

Michal created KAFKA-7250: - Summary: Kafka-Streams-Scala DSL transform shares transformer instance Key: KAFKA-7250 URL: https://issues.apache.org/jira/browse/KAFKA-7250 Project: Kafka Issue Type: Bu

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16569841#comment-16569841 ] ASF GitHub Bot commented on KAFKA-7183: --- rajinisivaram closed pull request #5393: K