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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782247#comment-16782247 ] Matthias J. Sax commented on KAFKA-7937: And again:

[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=16782246#comment-16782246 ] Matthias J. Sax commented on KAFKA-8026: Failed again:

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

[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782244#comment-16782244 ] Matthias J. Sax commented on KAFKA-7288: Failed again: 

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

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 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

[ 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

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

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

[ 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 >

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

[ https://issues.apache.org/jira/browse/KAFKA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782210#comment-16782210 ] Jun Rao commented on KAFKA-8018: Created a PR: https://github.com/apache/kafka/pull/6354 > Flaky Test >

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

[ 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 >

[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=16782206#comment-16782206 ] Matthias J. Sax commented on KAFKA-7994: Thanks [~vvcephei]. Sounds convincing! Glad that

[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: --- Component/s: unit tests core > Flaky test

[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: --- Affects Version/s: 2.3.0 > Flaky test

[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

[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 >

[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

[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=16782184#comment-16782184 ] Bill Bejeck commented on KAFKA-7651:

[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] [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-7419) Rolling sum for high frequency sream

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

[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-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=16782178#comment-16782178 ] John Roesler commented on KAFKA-7994: - I did some mental math when I made that last change to stream

[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=16782176#comment-16782176 ] Guozhang Wang commented on KAFKA-5122: -- It was not a leak, will mark as not a problem. > Kafka

[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-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] [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] [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-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-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] [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=16782175#comment-16782175 ] Guozhang Wang commented on KAFKA-7652: -- Hi [~jonathanpdx] we are not voting on the 2.2.0 RC1 right

[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] [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 >

[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] [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-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:

[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-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] [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

[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-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-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

[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] [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=16782144#comment-16782144 ] Matthias J. Sax commented on KAFKA-5122: [~guozhang] What is the fixed version for this? > Kafka

[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=16782143#comment-16782143 ] Guozhang Wang commented on KAFKA-7628: -- It was not a bug, I should mark it as "not a problem." >

[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] [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] [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] [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=16782139#comment-16782139 ] Jonathan Gordon commented on KAFKA-7652: That did it! This is really encouraging. Any chance

[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] [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] [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

[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

[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] [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] [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] [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] [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-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] [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] [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

[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

[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] [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] [Commented] (KAFKA-7628) KafkaStream is not closing

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

[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

[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] [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] [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] [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] [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] [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-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-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-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-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-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] [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

[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 >

[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] [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

[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:

[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=16781926#comment-16781926 ] Matthias J. Sax commented on KAFKA-7989: Failed again:

[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] [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:

[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=16781886#comment-16781886 ] Guozhang Wang commented on KAFKA-8026: -- [~bbejeck] I think you cherry-picked the PR to old branches

[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=16781883#comment-16781883 ] Matthias J. Sax commented on KAFKA-8011: Done: https://issues.apache.org/jira/browse/KAFKA-8026

[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=16781880#comment-16781880 ] Matthias J. Sax commented on KAFKA-8011: Your commit might be unrelated. It's older branches that

[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

[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=16781850#comment-16781850 ] Abhishek Mendhekar commented on KAFKA-8021: --- [~sriharsha] the issue is in 0.11 and higher

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

Konstantine Karantasis created KAFKA-8025: - Summary: Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls Key: KAFKA-8025 URL:

[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=16781816#comment-16781816 ] ASF GitHub Bot commented on KAFKA-7922: --- omkreddy commented on pull request #6322: KAFKA-7922:

[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=16781820#comment-16781820 ] Sriharsha Chintalapani commented on KAFKA-8021: --- [~amendhekar] have you noticed this issue

[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=16781755#comment-16781755 ] Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:10 PM: I've been able to

[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=16781755#comment-16781755 ] Bill Bejeck edited comment on KAFKA-8011 at 3/1/19 3:09 PM: I've been able to

  1   2   >