[jira] [Commented] (KAFKA-7927) Old command line tools should notify user when unsupported isolation-level parameter provided

[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772763#comment-16772763 ] Gabor Somogyi commented on KAFKA-7927: -- [~guozhang] updated, feel free to adjust...

[jira] [Updated] (KAFKA-7927) Old command line tools should notify user when unsupported isolation-level parameter provided

[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated KAFKA-7927: - Summary: Old command line tools should notify user when unsupported isolation-level parameter pro

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772793#comment-16772793 ] Nitay Kufert commented on KAFKA-5998: - Nothing much to add just that I am getting thi

[jira] [Updated] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Dickinson updated KAFKA-7958: Affects Version/s: (was: 2.1.1) 2.1.0 > Transactions are broken

[jira] [Updated] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Dickinson updated KAFKA-7958: Description: After a rolling re-start in a kubernetes-like environment, brokers may change

[jira] [Commented] (KAFKA-6586) Refactor Connect executables

[ https://issues.apache.org/jira/browse/KAFKA-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772833#comment-16772833 ] Ludvig Persson commented on KAFKA-6586: --- Hello! We are a group of 5 students who a

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772856#comment-16772856 ] Michael Bragg commented on KAFKA-7895: -- Hey [~vvcephei]  What would be a typical ET

[jira] [Issue Comment Deleted] (KAFKA-6586) Refactor Connect executables

[ https://issues.apache.org/jira/browse/KAFKA-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ludvig Persson updated KAFKA-6586: -- Comment: was deleted (was: Hello! We are a group of 5 students who are going to be working on

[jira] [Commented] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773101#comment-16773101 ] Ismael Juma commented on KAFKA-7958: Yes, there were a couple of issues related to DN

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7932: Description: Following on KAFKA-7763, Streams needs to handle the new behavior. See also [https://

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

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

[jira] [Commented] (KAFKA-7920) Do not permit zstd use until inter.broker.protocol.version is updated to 2.1

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

[jira] [Updated] (KAFKA-7920) Do not permit zstd use until inter.broker.protocol.version is updated to 2.1

[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7920: --- Affects Version/s: 2.1.1 > Do not permit zstd use until inter.broker.protocol.version is upda

[jira] [Created] (KAFKA-7959) Clear/delete epoch cache if old message format is in use

Jason Gustafson created KAFKA-7959: -- Summary: Clear/delete epoch cache if old message format is in use Key: KAFKA-7959 URL: https://issues.apache.org/jira/browse/KAFKA-7959 Project: Kafka Is

[jira] [Commented] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

[ https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773226#comment-16773226 ] Matthias J. Sax commented on KAFKA-7133: \cc [~guozhang] [~hachikuji] Any input o

[jira] [Created] (KAFKA-7960) KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

Ron Dagostino created KAFKA-7960: Summary: KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation Key: KAFKA-7960 URL: https://issues.apache.org/jira/browse/KAFKA-7960

[jira] [Created] (KAFKA-7961) Handle subscription changes with a rebalance in progress

Jason Gustafson created KAFKA-7961: -- Summary: Handle subscription changes with a rebalance in progress Key: KAFKA-7961 URL: https://issues.apache.org/jira/browse/KAFKA-7961 Project: Kafka Is

[jira] [Assigned] (KAFKA-7961) Handle subscription changes with a rebalance in progress

[ https://issues.apache.org/jira/browse/KAFKA-7961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-7961: -- Assignee: (was: Jason Gustafson) > Handle subscription changes with a rebalance in

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773259#comment-16773259 ] Matthias J. Sax commented on KAFKA-7190: [~guozhang] It seems that a workaround w

[jira] [Created] (KAFKA-7962) StickyAssignor: throws NullPointerException during assignments if topic is deleted

Oleg Smirnov created KAFKA-7962: --- Summary: StickyAssignor: throws NullPointerException during assignments if topic is deleted Key: KAFKA-7962 URL: https://issues.apache.org/jira/browse/KAFKA-7962 Projec

[jira] [Created] (KAFKA-7963) Extract hard-coded strings to centralized place

Sophie Blee-Goldman created KAFKA-7963: -- Summary: Extract hard-coded strings to centralized place Key: KAFKA-7963 URL: https://issues.apache.org/jira/browse/KAFKA-7963 Project: Kafka Iss

[jira] [Commented] (KAFKA-6359) Work for KIP-236

[ https://issues.apache.org/jira/browse/KAFKA-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773351#comment-16773351 ] GEORGE LI commented on KAFKA-6359: -- New Pull Request:   https://github.com/apache/kafka/

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773365#comment-16773365 ] Derek commented on KAFKA-6188: -- I have the same issue with 2.11-2.1.0. I run the demo app. K

[jira] [Commented] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned

[ https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773394#comment-16773394 ] GEORGE LI commented on KAFKA-6304: -- [KIP-236|https://cwiki.apache.org/confluence/display

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773395#comment-16773395 ] GEORGE LI commented on KAFKA-7854: -- [KIP-236|https://cwiki.apache.org/confluence/display

[jira] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

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

[jira] [Resolved] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7945. --- Resolution: Fixed Reviewer: Rajini Sivaram Fix Version/s: 2.1.2

[jira] [Assigned] (KAFKA-7961) Handle subscription changes with a rebalance in progress

[ https://issues.apache.org/jira/browse/KAFKA-7961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio reassigned KAFKA-7961: - Assignee: Jose Armando Garcia Sancio > Handle subscription chang

[jira] [Created] (KAFKA-7964) Flaky Test ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize

Matthias J. Sax created KAFKA-7964: -- Summary: Flaky Test ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize Key: KAFKA-7964 URL: https://issues.apache.org/jira/browse/KAFKA-7964

[jira] [Created] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

Matthias J. Sax created KAFKA-7965: -- Summary: Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup Key: KAFKA-7965 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773542#comment-16773542 ] Matthias J. Sax commented on KAFKA-7937: Happend again: [https://jenkins.confluen

[jira] [Created] (KAFKA-7966) Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig

Matthias J. Sax created KAFKA-7966: -- Summary: Flaky Test DynamicBrokerReconfigurationTest#testLogCleanerConfig Key: KAFKA-7966 URL: https://issues.apache.org/jira/browse/KAFKA-7966 Project: Kafka

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Fix Version/s: 2.2.0 > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmallerM

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Affects Version/s: 2.2.0 > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmal

[jira] [Commented] (KAFKA-7947) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest #shouldFollowLeaderEpochBasicWorkflow

[ https://issues.apache.org/jira/browse/KAFKA-7947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773546#comment-16773546 ] Matthias J. Sax commented on KAFKA-7947: Happend again: [https://jenkins.confluen

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Component/s: unit tests consumer > Flaky Test > ConsumerBounceTest#testRoll

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Component/s: clients > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmallerM

[jira] [Updated] (KAFKA-7964) Flaky Test ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize

[ https://issues.apache.org/jira/browse/KAFKA-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7964: --- Component/s: consumer > Flaky Test > ConsumerBounceTest#testConsumerReceivesFatalExceptionWh

[jira] [Updated] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7540: --- Component/s: clients > Transient failure: kafka.api.ConsumerBounceTest.testClose > --

[jira] [Updated] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7937: --- Component/s: clients > Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGro

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Priority: Critical (was: Major) > Flaky Test > ConsumerBounceTest#testRollingBrokerRestarts

[jira] [Updated] (KAFKA-7540) Transient failure: kafka.api.ConsumerBounceTest.testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7540: --- Component/s: (was: clients) consumer > Transient failure: kafka.api.Cons

[jira] [Commented] (KAFKA-4730) Streams does not have an in-memory windowed store

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

[jira] [Resolved] (KAFKA-4730) Streams does not have an in-memory windowed store

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4730. -- Resolution: Fixed Fix Version/s: 2.3.0 > Streams does not have an in-memory windowed sto

[jira] [Commented] (KAFKA-7951) Log Cleaner thread stop with "Varint is too long" error

[ https://issues.apache.org/jira/browse/KAFKA-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773631#comment-16773631 ] huxihx commented on KAFKA-7951: --- [~ninth.nails] Had you upgraded or downgraded the Kafka ve

[jira] [Comment Edited] (KAFKA-7951) Log Cleaner thread stop with "Varint is too long" error

[ https://issues.apache.org/jira/browse/KAFKA-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773631#comment-16773631 ] huxihx edited comment on KAFKA-7951 at 2/21/19 3:26 AM: [~ninth.n

[jira] [Updated] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ziming Dong updated KAFKA-7967: --- Description: We are using kafka streams 2.1.0, we use both persistentKeyValueStore statestore and pe

[jira] [Updated] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ziming Dong updated KAFKA-7967: --- Description: We are using kafka streams 2.1.0, we use both persistentKeyValueStore statestore and pe

[jira] [Created] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

Ziming Dong created KAFKA-7967: -- Summary: Kafka Streams: some values in statestore rollback to old value Key: KAFKA-7967 URL: https://issues.apache.org/jira/browse/KAFKA-7967 Project: Kafka Iss

[jira] [Resolved] (KAFKA-7283) mmap indexes lazily and skip sanity check for segments below recovery point

[ https://issues.apache.org/jira/browse/KAFKA-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7283. Resolution: Fixed Fix Version/s: 2.3.0 Merged the PR to trunk. > mmap indexes lazily and skip sanit

[jira] [Commented] (KAFKA-7283) mmap indexes lazily and skip sanity check for segments below recovery point

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

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773699#comment-16773699 ] Matthias J. Sax commented on KAFKA-7967: Thanks for reporting this. Can you share

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773703#comment-16773703 ] Matthias J. Sax commented on KAFKA-5998: Thanks [~pkleindl] and [~nitay.k]! > /.

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773714#comment-16773714 ] Matthias J. Sax commented on KAFKA-6460: Personally, I would not use EasyMock for

[jira] [Commented] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773750#comment-16773750 ] ASF GitHub Bot commented on KAFKA-7933: --- mjsax commented on pull request #6292: KAF

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773752#comment-16773752 ] Ziming Dong commented on KAFKA-7967: {code:java} final StreamsBuilder builder = new S

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773756#comment-16773756 ] Matthias J. Sax commented on KAFKA-7967: {quote}We thought cache is disabled by d

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773757#comment-16773757 ] Ziming Dong commented on KAFKA-7967: I'll try to enable DEBUG logging. > Kafka Strea

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773769#comment-16773769 ] ASF GitHub Bot commented on KAFKA-7930: --- mjsax commented on pull request #6267: KAF

[jira] [Commented] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773772#comment-16773772 ] Henri Yandell commented on KAFKA-7268: -- Will ping private@. > Review Handling Crypt

[jira] [Resolved] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7930. Resolution: Fixed Fix Version/s: 2.3.0 > StreamsResetter makes "changelog" topic nam

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773776#comment-16773776 ] Matthias J. Sax commented on KAFKA-7930: Thanks for the patch [~muradm]. Added y

[jira] [Assigned] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7930: -- Assignee: Murad M > StreamsResetter makes "changelog" topic naming assumptions > -