[jira] [Updated] (KAFKA-9912) Kafka deletes full log on startup written 30mins ago - wrongly claims retention time 7d breach

[ https://issues.apache.org/jira/browse/KAFKA-9912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Baltiyskiy updated KAFKA-9912: --- Description: This isn't easily reproduced, so I'll try to explain how I got there as accurat

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618658842 ok to test This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618658934 test This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [kafka] ConcurrencyPractitioner removed a comment on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner removed a comment on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618658842 ok to test This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #7884: [KAFKA-8522] Streamline tombstone and transaction marker removal

ConcurrencyPractitioner commented on pull request #7884: URL: https://github.com/apache/kafka/pull/7884#issuecomment-618659683 @junrao I don't think the .asf.yaml worked. Tried to trigger a few test rounds, but Jenkins didn't respond. --

[GitHub] [kafka] hachikuji commented on a change in pull request #8539: MINOR: equals() should compare all fields for generated classes

hachikuji commented on a change in pull request #8539: URL: https://github.com/apache/kafka/pull/8539#discussion_r414112419 ## File path: generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java ## @@ -2003,15 +2007,17 @@ private void generateStringToBytes(St

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618661849 @vvcephei Included your test changes in the PR. :) This is an automated message from the Apache Gi

[jira] [Created] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

Matthias J. Sax created KAFKA-9913: -- Summary: TopologyDescription should expose all topic name progrematically Key: KAFKA-9913 URL: https://issues.apache.org/jira/browse/KAFKA-9913 Project: Kafka

[GitHub] [kafka] junrao commented on pull request #7884: [KAFKA-8522] Streamline tombstone and transaction marker removal

junrao commented on pull request #7884: URL: https://github.com/apache/kafka/pull/7884#issuecomment-618669412 @ConcurrencyPractitioner Could you try "retest this please"? If it still doesn't work, you can file an Apache infra jira for help.

[GitHub] [kafka] ableegoldman opened a new pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

ableegoldman opened a new pull request #8540: URL: https://github.com/apache/kafka/pull/8540 This should fix the flaky `GlobalKTableIntegrationTest.shouldRestoreGlobalInMemoryKTableOnRestart` as well as address the issue on the ticket (avoid unnecessary group coordination overhead).

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618685777 retest this please This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618687469 test This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] lbradstreet commented on a change in pull request #8467: MINOR: reduce allocations in log start and recovery checkpoints

lbradstreet commented on a change in pull request #8467: URL: https://github.com/apache/kafka/pull/8467#discussion_r414151707 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File], /** * Map of log dir

[GitHub] [kafka] lbradstreet commented on a change in pull request #8467: MINOR: reduce allocations in log start and recovery checkpoints

lbradstreet commented on a change in pull request #8467: URL: https://github.com/apache/kafka/pull/8467#discussion_r414152352 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File], /** * Map of log dir

[GitHub] [kafka] ijuma commented on a change in pull request #8467: MINOR: reduce allocations in log start and recovery checkpoints

ijuma commented on a change in pull request #8467: URL: https://github.com/apache/kafka/pull/8467#discussion_r414162242 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File], /** * Map of log dir to log

[jira] [Commented] (KAFKA-9906) Is bytesSinceLastIndexEntry updated correctly in LogSegment.append()?

[ https://issues.apache.org/jira/browse/KAFKA-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090973#comment-17090973 ] Xiang Zhang commented on KAFKA-9906: cc [~guozhang] > Is bytesSinceLastIndexEntry up

[jira] [Updated] (KAFKA-9883) Connect request to restart task can result in IllegalArgumentError: "uriTemplate" parameter is null

[ https://issues.apache.org/jira/browse/KAFKA-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9883: - Fix Version/s: 2.5.1 2.4.2 2.6.0 > Connect request to resta

[jira] [Resolved] (KAFKA-9883) Connect request to restart task can result in IllegalArgumentError: "uriTemplate" parameter is null

[ https://issues.apache.org/jira/browse/KAFKA-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9883. -- Resolution: Fixed > Connect request to restart task can result in IllegalArgumentError: > "uri

[GitHub] [kafka] vvcephei commented on a change in pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

vvcephei commented on a change in pull request #8540: URL: https://github.com/apache/kafka/pull/8540#discussion_r414182534 ## File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java ## @@ -161,6 +165,9 @@ public void before() throws Exception {

[GitHub] [kafka] vvcephei opened a new pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei opened a new pull request #8541: URL: https://github.com/apache/kafka/pull/8541 * add a config to set the TaskAssignor * set the default assignor to HighAvailabilityTaskAssignor * fix broken tests ### Committer Checklist (excluded from commit message) - [ ] Verify de

[GitHub] [kafka] lbradstreet commented on a change in pull request #8467: MINOR: reduce allocations in log start and recovery checkpoints

lbradstreet commented on a change in pull request #8467: URL: https://github.com/apache/kafka/pull/8467#discussion_r414190233 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File], /** * Map of log dir

[GitHub] [kafka] ableegoldman commented on pull request #8248: KAFKA-9501: convert between active and standby without closing stores

ableegoldman commented on pull request #8248: URL: https://github.com/apache/kafka/pull/8248#issuecomment-618726059 Finally ready for review @vvcephei @cadonna @guozhangwang This is an automated message from the Apache Git S

[GitHub] [kafka] ableegoldman commented on a change in pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

ableegoldman commented on a change in pull request #8540: URL: https://github.com/apache/kafka/pull/8540#discussion_r414201107 ## File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java ## @@ -161,6 +165,9 @@ public void before() throws Exception {

[GitHub] [kafka] vvcephei commented on pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

vvcephei commented on pull request #8540: URL: https://github.com/apache/kafka/pull/8540#issuecomment-618729924 test this please This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] thspinto commented on pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

thspinto commented on pull request #7577: URL: https://github.com/apache/kafka/pull/7577#issuecomment-618732263 Could you post your configuration file @bseenu? This is an automated message from the Apache Git Service. To resp

[GitHub] [kafka] ning2008wisc commented on pull request #7577: KAFKA-9076: support consumer offset sync across clusters in MM 2.0

ning2008wisc commented on pull request #7577: URL: https://github.com/apache/kafka/pull/7577#issuecomment-618732741 Hi @bseenu , it will be very helpful to elaborate the operational sequence of your testing case? e.g. which cluster your consumer initially consume from? Did you switch your

[GitHub] [kafka] mjsax commented on a change in pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

mjsax commented on a change in pull request #8540: URL: https://github.com/apache/kafka/pull/8540#discussion_r414205108 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -701,18 +703,33 @@ private KafkaStreams(final InternalTopologyBuilder in

[GitHub] [kafka] vvcephei commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei commented on a change in pull request #8541: URL: https://github.com/apache/kafka/pull/8541#discussion_r414188592 ## File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java ## @@ -1146,4 +1146,13 @@ private static byte checkRange(final byte i) {

[GitHub] [kafka] vvcephei commented on a change in pull request #8540: KAFKA-9127: don't create StreamThreads for global-only topology

vvcephei commented on a change in pull request #8540: URL: https://github.com/apache/kafka/pull/8540#discussion_r414214864 ## File path: checkstyle/suppressions.xml ## @@ -181,7 +181,7 @@ files="StreamsPartitionAssignor.java"/> + files="(Ass

[jira] [Assigned] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9127: -- Assignee: Sophie Blee-Goldman > Needless group coordination overhead for Globa

[GitHub] [kafka] steverod opened a new pull request #8542: [KAFKA-9826] Handle an unaligned first dirty offset during log cleani…

steverod opened a new pull request #8542: URL: https://github.com/apache/kafka/pull/8542 …ng. (#8469) In KAFKA-9826, a log whose first dirty offset was past the start of the active segment and past the last cleaned point resulted in an endless cycle of picking the segment to clean a

[GitHub] [kafka] steverod opened a new pull request #8543: [KAFKA-9826] Handle an unaligned first dirty offset during log cleani…

steverod opened a new pull request #8543: URL: https://github.com/apache/kafka/pull/8543 …ng. (#8469) In KAFKA-9826, a log whose first dirty offset was past the start of the active segment and past the last cleaned point resulted in an endless cycle of picking the segment to clean a

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner commented on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618766447 ok to test This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [kafka] ConcurrencyPractitioner removed a comment on pull request #8254: KIP-557: Add Emit On Change Support

ConcurrencyPractitioner removed a comment on pull request #8254: URL: https://github.com/apache/kafka/pull/8254#issuecomment-618687469 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #7884: [KAFKA-8522] Streamline tombstone and transaction marker removal

ConcurrencyPractitioner commented on pull request #7884: URL: https://github.com/apache/kafka/pull/7884#issuecomment-618766295 @junrao Did try on another PR. Looks like it didn't work. I will fire a JIRA. This is an automated

[GitHub] [kafka] ableegoldman commented on a change in pull request #8248: KAFKA-9501: convert between active and standby without closing stores

ableegoldman commented on a change in pull request #8248: URL: https://github.com/apache/kafka/pull/8248#discussion_r414247204 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java ## @@ -148,6 +161,82 @@ public void

[GitHub] [kafka] ConcurrencyPractitioner commented on pull request #7884: [KAFKA-8522] Streamline tombstone and transaction marker removal

ConcurrencyPractitioner commented on pull request #7884: URL: https://github.com/apache/kafka/pull/7884#issuecomment-618768078 Reported in JIRA here: https://issues.apache.org/jira/browse/INFRA-20182 This is an automated mess

[GitHub] [kafka] ableegoldman commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

ableegoldman commented on a change in pull request #8541: URL: https://github.com/apache/kafka/pull/8541#discussion_r414227525 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java ## @@ -713,23 +713,18 @@ private boolea

[GitHub] [kafka] vvcephei commented on pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei commented on pull request #8541: URL: https://github.com/apache/kafka/pull/8541#issuecomment-618768435 Also, kicked off https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3915/ This is an automated me

[GitHub] [kafka] lbradstreet commented on a change in pull request #8518: MINOR: add support for kafka 2.4 and 2.5 to downgrade test

lbradstreet commented on a change in pull request #8518: URL: https://github.com/apache/kafka/pull/8518#discussion_r414250681 ## File path: tests/kafkatest/tests/core/downgrade_test.py ## @@ -67,11 +67,18 @@ def setup_services(self, kafka_version, compression_types, security_p

[GitHub] [kafka] vvcephei commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei commented on a change in pull request #8541: URL: https://github.com/apache/kafka/pull/8541#discussion_r414193901 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/PriorTaskAssignor.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to

[GitHub] [kafka] vvcephei commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei commented on a change in pull request #8541: URL: https://github.com/apache/kafka/pull/8541#discussion_r414195680 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java ## @@ -515,84 +520,114 @@ public void shouldNotViolateEo

[GitHub] [kafka] vvcephei commented on a change in pull request #8541: KAFKA-6145: KIP-441: Add TaskAssignor class config

vvcephei commented on a change in pull request #8541: URL: https://github.com/apache/kafka/pull/8541#discussion_r414251894 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java ## @@ -1,349 +0,0 @@ -/* - * Licensed to the Apache

[jira] [Commented] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

[ https://issues.apache.org/jira/browse/KAFKA-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091168#comment-17091168 ] Guozhang Wang commented on KAFKA-9913: -- [~mjsax] I will incorporate this ticket as p

[jira] [Comment Edited] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

[ https://issues.apache.org/jira/browse/KAFKA-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091168#comment-17091168 ] Guozhang Wang edited comment on KAFKA-9913 at 4/24/20, 4:32 AM: ---

[GitHub] [kafka] ijuma commented on a change in pull request #8467: MINOR: reduce allocations in log start and recovery checkpoints

ijuma commented on a change in pull request #8467: URL: https://github.com/apache/kafka/pull/8467#discussion_r414296613 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File], /** * Map of log dir to log

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091216#comment-17091216 ] Kin Siu commented on KAFKA-9859: I have been using 2.4.1 to perform application reset, bu

[jira] [Comment Edited] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091216#comment-17091216 ] Kin Siu edited comment on KAFKA-9859 at 4/24/20, 5:37 AM: -- I hav

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091227#comment-17091227 ] Tom Mau commented on KAFKA-9859: Looks like the topic pattern it looking for in `kafka.t

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Reopened] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze reopened KAFKA-9859: -- > kafka-streams-application-reset tool doesn't take into account topics > generated by KTa

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091236#comment-17091236 ] Levani Kokhreidze commented on KAFKA-9859: -- Thanks for spotting this, haven't pa

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091243#comment-17091243 ] Levani Kokhreidze commented on KAFKA-9859: -- Please also note that this problem o

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-9859: - Description: Steps to reproduce: * Create Kafka Streams application which uses foreign k

<    1   2