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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773776#comment-16773776 ] Matthias J. Sax commented on KAFKA-7930: Thanks for the patch [~muradm]. Added you to the list

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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

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

2019-02-20 Thread Henri Yandell (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773772#comment-16773772 ] Henri Yandell commented on KAFKA-7268: -- Will ping private@. > Review Handling Crypto Rules and

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773769#comment-16773769 ] ASF GitHub Bot commented on KAFKA-7930: --- mjsax commented on pull request #6267: KAFKA-7930: topic

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

2019-02-20 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773757#comment-16773757 ] Ziming Dong commented on KAFKA-7967: I'll try to enable DEBUG logging. > Kafka Streams: some values

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773756#comment-16773756 ] Matthias J. Sax commented on KAFKA-7967: {quote}We thought cache is disabled by default? {quote}

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

2019-02-20 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773752#comment-16773752 ] Ziming Dong commented on KAFKA-7967: {code:java} final StreamsBuilder builder = new StreamsBuilder();

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773750#comment-16773750 ] ASF GitHub Bot commented on KAFKA-7933: --- mjsax commented on pull request #6292: KAFKA-7933: Switch

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773714#comment-16773714 ] Matthias J. Sax commented on KAFKA-6460: Personally, I would not use EasyMock for this but

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773703#comment-16773703 ] Matthias J. Sax commented on KAFKA-5998: Thanks [~pkleindl] and [~nitay.k]! > /.checkpoint.tmp

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773699#comment-16773699 ] Matthias J. Sax commented on KAFKA-7967: Thanks for reporting this. Can you share your DSL code

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773683#comment-16773683 ] ASF GitHub Bot commented on KAFKA-7283: --- junrao commented on pull request #5498: KAFKA-7283: Enable

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

2019-02-20 Thread Jun Rao (JIRA)
[ 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

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

2019-02-20 Thread Ziming Dong (JIRA)
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

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

2019-02-20 Thread Ziming Dong (JIRA)
[ 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 

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

2019-02-20 Thread Ziming Dong (JIRA)
[ 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 

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

2019-02-20 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773631#comment-16773631 ] huxihx edited comment on KAFKA-7951 at 2/21/19 3:26 AM: [~ninth.nails] Had you

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

2019-02-20 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773631#comment-16773631 ] huxihx commented on KAFKA-7951: --- [~ninth.nails] Had you upgraded or downgraded the Kafka version before

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

2019-02-20 Thread Guozhang Wang (JIRA)
[ 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

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773625#comment-16773625 ] ASF GitHub Bot commented on KAFKA-4730: --- guozhangwang commented on pull request #6239: KAFKA-4730:

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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:

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773546#comment-16773546 ] Matthias J. Sax commented on KAFKA-7947: Happend again:

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ 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 >

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

2019-02-20 Thread Matthias J. Sax (JIRA)
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] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773542#comment-16773542 ] Matthias J. Sax commented on KAFKA-7937: Happend again:

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

2019-02-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-7965: -- Summary: Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup Key: KAFKA-7965 URL:

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

2019-02-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-7964: -- Summary: Flaky Test ConsumerBounceTest#testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize Key: KAFKA-7964 URL: https://issues.apache.org/jira/browse/KAFKA-7964

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

2019-02-20 Thread Jose Armando Garcia Sancio (JIRA)
[ 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

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

2019-02-20 Thread Rajini Sivaram (JIRA)
[ 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] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773403#comment-16773403 ] ASF GitHub Bot commented on KAFKA-7945: --- rajinisivaram commented on pull request #6288: KAFKA-7945:

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

2019-02-20 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773395#comment-16773395 ] GEORGE LI commented on KAFKA-7854: --

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

2019-02-20 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773394#comment-16773394 ] GEORGE LI commented on KAFKA-6304: --

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

2019-02-20 Thread Derek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773365#comment-16773365 ] Derek commented on KAFKA-6188: -- I have the same issue with 2.11-2.1.0. I run the demo app. Kafka shutdown

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

2019-02-20 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773351#comment-16773351 ] GEORGE LI commented on KAFKA-6359: -- New Pull Request:   https://github.com/apache/kafka/pull/6296 >

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

2019-02-20 Thread Sophie Blee-Goldman (JIRA)
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

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

2019-02-20 Thread Oleg Smirnov (JIRA)
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

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

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773259#comment-16773259 ] Matthias J. Sax commented on KAFKA-7190: [~guozhang] It seems that a workaround would be to

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

2019-02-20 Thread Jason Gustafson (JIRA)
[ 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

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

2019-02-20 Thread Jason Gustafson (JIRA)
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

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

2019-02-20 Thread Ron Dagostino (JIRA)
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] [Commented] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

2019-02-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773226#comment-16773226 ] Matthias J. Sax commented on KAFKA-7133: \cc [~guozhang] [~hachikuji] Any input on this? >

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

2019-02-20 Thread Jason Gustafson (JIRA)
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

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

2019-02-20 Thread Jason Gustafson (JIRA)
[ 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

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773178#comment-16773178 ] ASF GitHub Bot commented on KAFKA-7920: --- hachikuji commented on pull request #6256: KAFKA-7920: Do

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

2019-02-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773103#comment-16773103 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6286: KAFKA-7895: fix

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

2019-02-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773101#comment-16773101 ] Ismael Juma commented on KAFKA-7958: Yes, there were a couple of issues related to DNS refresh that

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

2019-02-20 Thread John Roesler (JIRA)
[ 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 

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

2019-02-20 Thread Ludvig Persson (JIRA)
[ 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-7895) Ktable supress operator emitting more than one record for the same key per window

2019-02-20 Thread Michael Bragg (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772856#comment-16772856 ] Michael Bragg commented on KAFKA-7895: -- Hey [~vvcephei]  What would be a typical ETA of this fix

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

2019-02-20 Thread Ludvig Persson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772833#comment-16772833 ] Ludvig Persson commented on KAFKA-6586: --- Hello! We are a group of 5 students who are going to be

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

2019-02-20 Thread Thomas Dickinson (JIRA)
[ 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] [Updated] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2019-02-20 Thread Thomas Dickinson (JIRA)
[ 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] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-02-20 Thread Nitay Kufert (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772793#comment-16772793 ] Nitay Kufert commented on KAFKA-5998: - Nothing much to add just that I am getting this as well

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

2019-02-20 Thread Gabor Somogyi (JIRA)
[ 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

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

2019-02-20 Thread Gabor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772763#comment-16772763 ] Gabor Somogyi commented on KAFKA-7927: -- [~guozhang] updated, feel free to adjust... > Old command