[jira] [Updated] (KAFKA-7950) Kafka tools GetOffsetShell -time description

2019-03-01 Thread Kartik (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kartik updated KAFKA-7950: -- Issue Type: Wish (was: Improvement) > Kafka tools GetOffsetShell -time description >

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782247#comment-16782247 ] Matthias J. Sax commented on KAFKA-7937: And again: [https://builds.apache.org/b

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782246#comment-16782246 ] Matthias J. Sax commented on KAFKA-8026: Failed again: [https://builds.apache.or

[jira] [Commented] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782244#comment-16782244 ] Matthias J. Sax commented on KAFKA-7288: Failed again:  https://builds.apache.org

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4730: --- Description: Streams has windowed persistent stores (e.g., see PersistentKeyValueFactory int

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4730: --- Labels: kip (was: ) > Streams does not have an in-memory windowed store > --

[jira] [Updated] (KAFKA-8029) Add in-memory bytes-only session store implementation

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8029: --- Labels: needs-kip (was: ) > Add in-memory bytes-only session store implementation >

[jira] [Created] (KAFKA-8029) Add in-memory bytes-only session store implementation

2019-03-01 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-8029: Summary: Add in-memory bytes-only session store implementation Key: KAFKA-8029 URL: https://issues.apache.org/jira/browse/KAFKA-8029 Project: Kafka Issue Typ

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8025: --- Affects Version/s: 2.3.0 > Flaky Test > RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsA

[jira] [Commented] (KAFKA-7977) Flaky Test ReassignPartitionsClusterTest#shouldOnlyThrottleMovingReplicas

2019-03-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782211#comment-16782211 ] Jun Rao commented on KAFKA-7977: The PR in https://issues.apache.org/jira/browse/KAFKA-80

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

2019-03-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782210#comment-16782210 ] Jun Rao commented on KAFKA-8018: Created a PR: https://github.com/apache/kafka/pull/6354

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8025: --- Fix Version/s: 2.3.0 > Flaky Test > RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapt

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782206#comment-16782206 ] Matthias J. Sax commented on KAFKA-7994: Thanks [~vvcephei]. Sounds convincing! G

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7651: --- Component/s: unit tests core > Flaky test SaslSslAdminClientIntegrationTest.

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7651: --- Affects Version/s: 2.3.0 > Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTim

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

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

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

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

2019-03-01 Thread Bill Bejeck (JIRA)
[ 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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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-7419) Rolling sum for high frequency sream

2019-03-01 Thread John Roesler (JIRA)
[ 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] [Reopened] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7994) Improve Stream-Time for rebalances and restarts

2019-03-01 Thread John Roesler (JIRA)
[ 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-5122) Kafka Streams unexpected off-heap memory growth

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

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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] [Resolved] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-4721) KafkaStreams (and possibly others) should inherit Closeable

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-4281) Should be able to forward aggregation values immediately

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-4186) Transient failure in KStreamAggregationIntegrationTest

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-4694) Streams smoke tests fails when there is only 1 broker

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-4849) Bug in KafkaStreams documentation

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7628) KafkaStream is not closing

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-7628) KafkaStream is not closing

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-7628) KafkaStream is not closing

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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] [Updated] (KAFKA-5156) Options for handling exceptions in streams

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-5551) StreamThread should not expose methods for testing

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-5551) StreamThread should not expose methods for testing

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-03-01 Thread Jonathan Gordon (JIRA)
[ 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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-5652) Add new api methods to KStream

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-03-01 Thread Jonathan Gordon (JIRA)
[ 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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-7419) Rolling sum for high frequency sream

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-5825) Streams not processing when exactly once is set

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-5825) Streams not processing when exactly once is set

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-5893) ResetIntegrationTest fails

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-6462) ResetIntegrationTest unstable

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

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-7419) Rolling sum for high frequency sream

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-7628) KafkaStream is not closing

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-7221) Add Build method to StreamsBuilder accepting Properties

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-3770) KStream job should be able to specify linger.ms

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Reopened] (KAFKA-3770) KStream job should be able to specify linger.ms

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-3429) Remove Serdes needed for repartitioning in KTable stateful operations

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-6707) The default value for config of Type.LONG should be *L

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7492) Explain `null` handling for reduce and aggregate

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7918) Streams store cleanup: inline byte-store generic parameters

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-7912) In-memory key-value store does not support concurrent access

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Created] (KAFKA-8028) Kafka - ACL remove

2019-03-01 Thread Sathish Yanamala (JIRA)
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] [Assigned] (KAFKA-8018) Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed

2019-03-01 Thread Jun Rao (JIRA)
[ 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] [Resolved] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ 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] [Updated] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

2019-03-01 Thread Prashant (JIRA)
[ 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] [Created] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

2019-03-01 Thread Prashant (JIRA)
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] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Resolved] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ 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] [Created] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

2019-03-01 Thread Matthias J. Sax (JIRA)
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] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

2019-03-01 Thread Matthias J. Sax (JIRA)
[ 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] [Updated] (KAFKA-8023) Improve global state store restoration by using multiple update threads

2019-03-01 Thread Guozhang Wang (JIRA)
[ 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-8021) KafkaProducer.flush() can show unexpected behavior when a batch is split

2019-03-01 Thread Abhishek Mendhekar (JIRA)
[ 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] [Created] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

2019-03-01 Thread Konstantine Karantasis (JIRA)
Konstantine Karantasis created KAFKA-8025: - Summary: Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls Key: KAFKA-8025 URL: https://issues.apache.org/

  1   2   >