[jira] [Created] (KAFKA-8023) Improve global state store restoration by using multiple update threads

Patrik Kleindl created KAFKA-8023: - Summary: Improve global state store restoration by using multiple update threads Key: KAFKA-8023 URL: https://issues.apache.org/jira/browse/KAFKA-8023 Project: Kafk

[jira] [Comment Edited] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780986#comment-16780986 ] Jan Mynařík edited comment on KAFKA-6582 at 3/1/19 9:53 AM: D

[jira] [Created] (KAFKA-8024) UtilsTest.testFormatBytes fails with german locale

Patrik Kleindl created KAFKA-8024: - Summary: UtilsTest.testFormatBytes fails with german locale Key: KAFKA-8024 URL: https://issues.apache.org/jira/browse/KAFKA-8024 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-8024) UtilsTest.testFormatBytes fails with german locale

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

[jira] [Commented] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781557#comment-16781557 ] Sergei commented on KAFKA-4650: --- I will write tests for classes TimeWindow and UnlimitedWin

[jira] [Issue Comment Deleted] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei updated KAFKA-4650: -- Comment: was deleted (was: I will write tests for classes TimeWindow and UnlimitedWindow) > Improve test cover

[jira] [Commented] (KAFKA-7922) Returned authorized operations in describe responses (KIP-430)

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

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781704#comment-16781704 ] Valeria Vasylieva commented on KAFKA-7157: -- Issue can be still reproduced, [~rha

[jira] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8011: --- Attachment: streams_1_1_tests.png streams_1_0_test_results.png > Flaky Test RegexSour

[jira] [Assigned] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeria Vasylieva reassigned KAFKA-7157: Assignee: Valeria Vasylieva > Connect TimestampConverter SMT doesn't handle null v

[jira] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781755#comment-16781755 ] Bill Bejeck commented on KAFKA-8011: I've been able to verify that both 1.0 and 1.1 t

[jira] [Comment Edited] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781755#comment-16781755 ] Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:09 PM: I

[jira] [Comment Edited] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781755#comment-16781755 ] Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:10 PM: I

[jira] [Commented] (KAFKA-8021) KafkaProducer.flush() can show unexpected behavior when a batch is split

[ https://issues.apache.org/jira/browse/KAFKA-8021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781820#comment-16781820 ] Sriharsha Chintalapani commented on KAFKA-8021: --- [~amendhekar] have you not

[jira] [Commented] (KAFKA-7922) Returned authorized operations in describe responses (KIP-430)

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

[jira] [Created] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

Konstantine Karantasis created KAFKA-8025: - Summary: Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls Key: KAFKA-8025 URL: https://issues.apache.org/

[jira] [Commented] (KAFKA-8021) KafkaProducer.flush() can show unexpected behavior when a batch is split

[ https://issues.apache.org/jira/browse/KAFKA-8021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781850#comment-16781850 ] Abhishek Mendhekar commented on KAFKA-8021: --- [~sriharsha] the issue is in 0.11

[jira] [Updated] (KAFKA-8023) Improve global state store restoration by using multiple update threads

[ https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8023: - Labels: performance (was: ) > Improve global state store restoration by using multiple update th

[jira] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781880#comment-16781880 ] Matthias J. Sax commented on KAFKA-8011: Your commit might be unrelated. It's old

[jira] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781883#comment-16781883 ] Matthias J. Sax commented on KAFKA-8011: Done: https://issues.apache.org/jira/bro

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781886#comment-16781886 ] Guozhang Wang commented on KAFKA-8026: -- [~bbejeck] I think you cherry-picked the PR

[jira] [Created] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

Matthias J. Sax created KAFKA-8026: -- Summary: Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted Key: KAFKA-8026 URL: https://issues.apache.org/jira/browse/KAFKA-8026 Project: K

[jira] [Resolved] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7918. Resolution: Fixed > Streams store cleanup: inline byte-store generic parameters > -

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

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

[jira] [Created] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

Prashant created KAFKA-8027: --- Summary: Gradual decline in performance of CachingWindowStore provider when number of keys grow Key: KAFKA-8027 URL: https://issues.apache.org/jira/browse/KAFKA-8027 Project: K

[jira] [Updated] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

[ https://issues.apache.org/jira/browse/KAFKA-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prashant updated KAFKA-8027: Description: We observed this during a performance test of our stream application which tracks user's acti

[jira] [Resolved] (KAFKA-7912) In-memory key-value store does not support concurrent access

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7912. Resolution: Fixed > In-memory key-value store does not support concurrent access >

[jira] [Assigned] (KAFKA-8018) Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed

[ https://issues.apache.org/jira/browse/KAFKA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-8018: -- Assignee: Jun Rao > Flaky Test > SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrRetur

[jira] [Created] (KAFKA-8028) Kafka - ACL remove

Sathish Yanamala created KAFKA-8028: --- Summary: Kafka - ACL remove Key: KAFKA-8028 URL: https://issues.apache.org/jira/browse/KAFKA-8028 Project: Kafka Issue Type: Task Reporter

[jira] [Updated] (KAFKA-7912) In-memory key-value store does not support concurrent access

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7912: --- Fix Version/s: 2.3.0 > In-memory key-value store does not support concurrent access > --

[jira] [Updated] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7918: --- Fix Version/s: 2.3.0 > Streams store cleanup: inline byte-store generic parameters >

[jira] [Updated] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7492: --- Fix Version/s: 2.3.0 > Explain `null` handling for reduce and aggregate > ---

[jira] [Updated] (KAFKA-6707) The default value for config of Type.LONG should be *L

[ https://issues.apache.org/jira/browse/KAFKA-6707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6707: --- Fix Version/s: 2.0.0 > The default value for config of Type.LONG should be *L > -

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3429: --- Fix Version/s: 1.0.0 > Remove Serdes needed for repartitioning in KTable stateful operations

[jira] [Updated] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3758: --- Fix Version/s: 0.11.0.1 > KStream job fails to recover after Kafka broker stopped > -

[jira] [Updated] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3752: --- Fix Version/s: 0.10.1.0 > Provide a way for KStreams to recover from unclean shutdown > -

[jira] [Reopened] (KAFKA-3770) KStream job should be able to specify linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3770: > KStream job should be able to specify linger.ms > ---

[jira] [Resolved] (KAFKA-3770) KStream job should be able to specify linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3770. Resolution: Duplicate > KStream job should be able to specify linger.ms > -

[jira] [Resolved] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

[ https://issues.apache.org/jira/browse/KAFKA-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7221. Resolution: Duplicate > Add Build method to StreamsBuilder accepting Properties >

[jira] [Reopened] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

[ https://issues.apache.org/jira/browse/KAFKA-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7221: > Add Build method to StreamsBuilder accepting Properties > --

[jira] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8011: --- Fix Version/s: 2.1.2 2.3.0 2.0.2 2.2.

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782124#comment-16782124 ] Matthias J. Sax commented on KAFKA-7628: [~guozhang] What is the fixed version fo

[jira] [Resolved] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7419. Resolution: Not A Problem > Rolling sum for high frequency sream >

[jira] [Updated] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method

[ https://issues.apache.org/jira/browse/KAFKA-6702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6702: --- Fix Version/s: 2.0.0 > Wrong className in LoggerFactory.getLogger method > --

[jira] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6592: > NullPointerException thrown when executing ConsoleCosumer with deserializer > set to `Window

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6592. Resolution: Duplicate > NullPointerException thrown when executing ConsoleCosumer with dese

[jira] [Updated] (KAFKA-6462) ResetIntegrationTest unstable

[ https://issues.apache.org/jira/browse/KAFKA-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6462: --- Fix Version/s: 1.1.0 > ResetIntegrationTest unstable > - > >

[jira] [Updated] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6472: --- Fix Version/s: 2.0.0 > WordCount example code error > > >

[jira] [Updated] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6461: --- Fix Version/s: 1.1.0 > TableTableJoinIntegrationTest is unstable if caching is enabled >

[jira] [Reopened] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

[ https://issues.apache.org/jira/browse/KAFKA-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6092: > Time passed in punctuate call is currentTime, not punctuate schedule time. > ---

[jira] [Updated] (KAFKA-5893) ResetIntegrationTest fails

[ https://issues.apache.org/jira/browse/KAFKA-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5893: --- Fix Version/s: 1.0.0 > ResetIntegrationTest fails > -- > >

[jira] [Resolved] (KAFKA-5825) Streams not processing when exactly once is set

[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5825. Resolution: Not A Bug > Streams not processing when exactly once is set > -

[jira] [Reopened] (KAFKA-5825) Streams not processing when exactly once is set

[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5825: > Streams not processing when exactly once is set > ---

[jira] [Reopened] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7419: > Rolling sum for high frequency sream > > >

[jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Gordon updated KAFKA-7652: --- Attachment: 2.3.0-7652-NamedCache.txt > Kafka Streams Session store performance degradation f

[jira] [Updated] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

[ https://issues.apache.org/jira/browse/KAFKA-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5702: --- Fix Version/s: 1.0.0 > Refactor StreamThread to separate concerns and enable better testabili

[jira] [Updated] (KAFKA-5652) Add new api methods to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5652: --- Fix Version/s: 1.0.0 > Add new api methods to KStream > -- > >

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782139#comment-16782139 ] Jonathan Gordon commented on KAFKA-7652: That did it! This is really encouraging.

[jira] [Updated] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2

[ https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5571: --- Fix Version/s: 1.1.0 > Possible deadlock during shutdown in setState in kafka streams 10.2 >

[jira] [Reopened] (KAFKA-5551) StreamThread should not expose methods for testing

[ https://issues.apache.org/jira/browse/KAFKA-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5551: > StreamThread should not expose methods for testing >

[jira] [Updated] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2

[ https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5571: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Possible deadlock during shutdown

[jira] [Resolved] (KAFKA-5551) StreamThread should not expose methods for testing

[ https://issues.apache.org/jira/browse/KAFKA-5551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5551. Resolution: Duplicate > StreamThread should not expose methods for testing > --

[jira] [Updated] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5156: --- Fix Version/s: 1.1.0 > Options for handling exceptions in streams > -

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782143#comment-16782143 ] Guozhang Wang commented on KAFKA-7628: -- It was not a bug, I should mark it as "not a

[jira] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782144#comment-16782144 ] Matthias J. Sax commented on KAFKA-5122: [~guozhang] What is the fixed version fo

[jira] [Reopened] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-7628: -- > KafkaStream is not closing > -- > > Key: KAFKA-7628 >

[jira] [Resolved] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

[ https://issues.apache.org/jira/browse/KAFKA-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6092. Resolution: Not A Problem > Time passed in punctuate call is currentTime, not punctuate sch

[jira] [Resolved] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7628. -- Resolution: Not A Problem > KafkaStream is not closing > -- > >

[jira] [Resolved] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4953. Resolution: Duplicate > Global Store: cast exception when initialising with in-memory logge

[jira] [Reopened] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4953: > Global Store: cast exception when initialising with in-memory logged state > store > ---

[jira] [Resolved] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4849. Resolution: Duplicate (was: Fixed) > Bug in KafkaStreams documentation > -

[jira] [Reopened] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

[ https://issues.apache.org/jira/browse/KAFKA-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4732: > Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1] > -

[jira] [Resolved] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

[ https://issues.apache.org/jira/browse/KAFKA-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4732. Resolution: Duplicate > Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPe

[jira] [Updated] (KAFKA-4694) Streams smoke tests fails when there is only 1 broker

[ https://issues.apache.org/jira/browse/KAFKA-4694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4694: --- Fix Version/s: 0.10.2.0 > Streams smoke tests fails when there is only 1 broker > ---

[jira] [Resolved] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable

[ https://issues.apache.org/jira/browse/KAFKA-4721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4721. Resolution: Duplicate > KafkaStreams (and possibly others) should inherit Closeable > -

[jira] [Reopened] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5063: > Flaky > ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[jira] [Resolved] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5063. Resolution: Cannot Reproduce > Flaky > ResetIntegrationTest.testReprocessingFromScratchAft

[jira] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4601: --- Fix Version/s: 2.1.0 > Avoid duplicated repartitioning in KStream DSL > -

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782175#comment-16782175 ] Guozhang Wang commented on KAFKA-7652: -- Hi [~jonathanpdx] we are not voting on the 2

[jira] [Resolved] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4186. Resolution: Cannot Reproduce > Transient failure in KStreamAggregationIntegrationTest > ---

[jira] [Resolved] (KAFKA-4281) Should be able to forward aggregation values immediately

[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4281. Resolution: Duplicate > Should be able to forward aggregation values immediately >

[jira] [Reopened] (KAFKA-4281) Should be able to forward aggregation values immediately

[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4281: > Should be able to forward aggregation values immediately > --

[jira] [Resolved] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging

[ https://issues.apache.org/jira/browse/KAFKA-3884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3884. Resolution: Duplicate > KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging >

[jira] [Reopened] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging

[ https://issues.apache.org/jira/browse/KAFKA-3884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3884: > KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging > -

[jira] [Reopened] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable

[ https://issues.apache.org/jira/browse/KAFKA-4721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4721: > KafkaStreams (and possibly others) should inherit Closeable > ---

[jira] [Resolved] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

[ https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3826. Resolution: Duplicate > Sampling on throughput / latency metrics recording in Streams > ---

[jira] [Reopened] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

[ https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3826: > Sampling on throughput / latency metrics recording in Streams > -

[jira] [Reopened] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5122: -- > Kafka Streams unexpected off-heap memory growth > ---

[jira] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782176#comment-16782176 ] Guozhang Wang commented on KAFKA-5122: -- It was not a leak, will mark as not a proble

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782178#comment-16782178 ] John Roesler commented on KAFKA-7994: - I did some mental math when I made that last c

[jira] [Reopened] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4186: > Transient failure in KStreamAggregationIntegrationTest >

[jira] [Commented] (KAFKA-7419) Rolling sum for high frequency sream

[ https://issues.apache.org/jira/browse/KAFKA-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782181#comment-16782181 ] John Roesler commented on KAFKA-7419: - Oh, good! > Rolling sum for high frequency sr

[jira] [Resolved] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5122. -- Resolution: Not A Problem > Kafka Streams unexpected off-heap memory growth > -

[jira] [Commented] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782184#comment-16782184 ] Bill Bejeck commented on KAFKA-7651: kafka.api.SaslSslAdminClientIntegrationTest.test

[jira] [Updated] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4474: --- Fix Version/s: 0.11.0.0 > Poor kafka-streams throughput > - > >

[jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7651: --- Priority: Critical (was: Major) > Flaky test SaslSslAdminClientIntegrationTest.testMinimumRe

[jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7651: --- Labels: flaky-test (was: ) > Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequest

[jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7651: --- Fix Version/s: 2.3.0 > Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeout

[jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7652: - Fix Version/s: (was: 2.2.0) > Kafka Streams Session store performance degradation from 0.10.2

[jira] [Reopened] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-7652: -- > Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 > -

  1   2   >