[jira] [Created] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

Matthias J. Sax created KAFKA-8122: -- Summary: Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState Key: KAFKA-8122 URL: https://issues.apache.org/jira/browse/KAFKA-8122 Project:

[jira] [Created] (KAFKA-8117) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoProduceWithDescribeAcl

Matthias J. Sax created KAFKA-8117: -- Summary: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoProduceWithDescribeAcl Key: KAFKA-8117 URL: https://issues.apache.org/jira/browse/KAFKA-8117

[jira] [Created] (KAFKA-8116) Add Kafka Streams archetype for Java11

Matthias J. Sax created KAFKA-8116: -- Summary: Add Kafka Streams archetype for Java11 Key: KAFKA-8116 URL: https://issues.apache.org/jira/browse/KAFKA-8116 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

Matthias J. Sax created KAFKA-8115: -- Summary: Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated Key: KAFKA-8115 URL: https://issues.apache.org/jira/browse/KAFKA-8115 Project: Kafka

[jira] [Created] (KAFKA-8114) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoGroupAcl

Matthias J. Sax created KAFKA-8114: -- Summary: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoGroupAcl Key: KAFKA-8114 URL: https://issues.apache.org/jira/browse/KAFKA-8114 Project: Kafka

[jira] [Created] (KAFKA-8113) Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch

Matthias J. Sax created KAFKA-8113: -- Summary: Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch Key: KAFKA-8113 URL: https://issues.apache.org/jira/browse/KAFKA-8113 Project: Kafka

[jira] [Created] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

Matthias J. Sax created KAFKA-8110: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions Key: KAFKA-8110 URL: https://issues.apache.org/jira/browse/KAFKA-8110

[jira] [Created] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

Matthias J. Sax created KAFKA-8098: -- Summary: Flaky Test AdminClientIntegrationTest#testConsumerGroups Key: KAFKA-8098 URL: https://issues.apache.org/jira/browse/KAFKA-8098 Project: Kafka

[jira] [Created] (KAFKA-8093) Fix JavaDoc markup

Matthias J. Sax created KAFKA-8093: -- Summary: Fix JavaDoc markup Key: KAFKA-8093 URL: https://issues.apache.org/jira/browse/KAFKA-8093 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-8092) Flaky Test GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroupDescribeAccess

Matthias J. Sax created KAFKA-8092: -- Summary: Flaky Test GroupAuthorizerIntegrationTest#testSendOffsetsWithNoConsumerGroupDescribeAccess Key: KAFKA-8092 URL: https://issues.apache.org/jira/browse/KAFKA-8092

[jira] [Created] (KAFKA-8088) Deprecate `WindowStoreIterator` interface

Matthias J. Sax created KAFKA-8088: -- Summary: Deprecate `WindowStoreIterator` interface Key: KAFKA-8088 URL: https://issues.apache.org/jira/browse/KAFKA-8088 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8087) Flaky Test PlaintextConsumerTest#testConsumingWithNullGroupId

Matthias J. Sax created KAFKA-8087: -- Summary: Flaky Test PlaintextConsumerTest#testConsumingWithNullGroupId Key: KAFKA-8087 URL: https://issues.apache.org/jira/browse/KAFKA-8087 Project: Kafka

[jira] [Created] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead

Matthias J. Sax created KAFKA-8086: -- Summary: Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead Key: KAFKA-8086 URL: https://issues.apache.org/jira/browse/KAFKA-8086

[jira] [Created] (KAFKA-8085) Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsByDuration

Matthias J. Sax created KAFKA-8085: -- Summary: Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsByDuration Key: KAFKA-8085 URL: https://issues.apache.org/jira/browse/KAFKA-8085 Project: Kafka

[jira] [Resolved] (KAFKA-5189) trunk unstable - DescribeConsumerGroupTest.testDescribeGroupWithNewConsumerWithShortInitializationTimeout fails 90% of times

[ https://issues.apache.org/jira/browse/KAFKA-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5189. Resolution: Fixed > trunk unstable - >

[jira] [Created] (KAFKA-8084) Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroupWithNoMembers

Matthias J. Sax created KAFKA-8084: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroupWithNoMembers Key: KAFKA-8084 URL: https://issues.apache.org/jira/browse/KAFKA-8084

[jira] [Created] (KAFKA-8083) Flaky Test DelegationTokenRequestsTest#testDelegationTokenRequests

Matthias J. Sax created KAFKA-8083: -- Summary: Flaky Test DelegationTokenRequestsTest#testDelegationTokenRequests Key: KAFKA-8083 URL: https://issues.apache.org/jira/browse/KAFKA-8083 Project: Kafka

[jira] [Created] (KAFKA-8082) Flaky Test ProducerFailureHandlingTest#testNotEnoughReplicasAfterBrokerShutdown

Matthias J. Sax created KAFKA-8082: -- Summary: Flaky Test ProducerFailureHandlingTest#testNotEnoughReplicasAfterBrokerShutdown Key: KAFKA-8082 URL: https://issues.apache.org/jira/browse/KAFKA-8082

[jira] [Created] (KAFKA-8081) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitions

Matthias J. Sax created KAFKA-8081: -- Summary: Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitions Key: KAFKA-8081 URL: https://issues.apache.org/jira/browse/KAFKA-8081

[jira] [Created] (KAFKA-8079) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLeaderChange

Matthias J. Sax created KAFKA-8079: -- Summary: Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLeaderChange Key: KAFKA-8079 URL: https://issues.apache.org/jira/browse/KAFKA-8079

[jira] [Created] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

Matthias J. Sax created KAFKA-8078: -- Summary: Flaky Test TableTableJoinIntegrationTest#testInnerInner Key: KAFKA-8078 URL: https://issues.apache.org/jira/browse/KAFKA-8078 Project: Kafka

[jira] [Created] (KAFKA-8077) Flaky Test AdminClientIntegrationTest#testConsumeAfterDeleteRecords

Matthias J. Sax created KAFKA-8077: -- Summary: Flaky Test AdminClientIntegrationTest#testConsumeAfterDeleteRecords Key: KAFKA-8077 URL: https://issues.apache.org/jira/browse/KAFKA-8077 Project: Kafka

[jira] [Reopened] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-2933: Reopening this. Failed again in 2.2:

[jira] [Created] (KAFKA-8076) Flaky Test ProduceRequestTest#testSimpleProduceRequest

Matthias J. Sax created KAFKA-8076: -- Summary: Flaky Test ProduceRequestTest#testSimpleProduceRequest Key: KAFKA-8076 URL: https://issues.apache.org/jira/browse/KAFKA-8076 Project: Kafka

[jira] [Created] (KAFKA-8075) Flaky Test GroupAuthorizerIntegrationTest#testTransactionalProducerTopicAuthorizationExceptionInCommit

Matthias J. Sax created KAFKA-8075: -- Summary: Flaky Test GroupAuthorizerIntegrationTest#testTransactionalProducerTopicAuthorizationExceptionInCommit Key: KAFKA-8075 URL:

[jira] [Created] (KAFKA-8068) Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroup

Matthias J. Sax created KAFKA-8068: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeMembersOfExistingGroup Key: KAFKA-8068 URL: https://issues.apache.org/jira/browse/KAFKA-8068 Project:

[jira] [Reopened] (KAFKA-5141) WorkerTest.testCleanupTasksOnStop transient failure due to NPE

[ https://issues.apache.org/jira/browse/KAFKA-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5141: This happened again:

[jira] [Created] (KAFKA-8065) Forwarding modified timestamps does not reset timestamp correctly

Matthias J. Sax created KAFKA-8065: -- Summary: Forwarding modified timestamps does not reset timestamp correctly Key: KAFKA-8065 URL: https://issues.apache.org/jira/browse/KAFKA-8065 Project: Kafka

[jira] [Created] (KAFKA-8064) Flaky Test DeleteTopicTest #testRecreateTopicAfterDeletion

Matthias J. Sax created KAFKA-8064: -- Summary: Flaky Test DeleteTopicTest #testRecreateTopicAfterDeletion Key: KAFKA-8064 URL: https://issues.apache.org/jira/browse/KAFKA-8064 Project: Kafka

[jira] [Created] (KAFKA-8063) Flaky Test WorkerTest#testConverterOverrides

Matthias J. Sax created KAFKA-8063: -- Summary: Flaky Test WorkerTest#testConverterOverrides Key: KAFKA-8063 URL: https://issues.apache.org/jira/browse/KAFKA-8063 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

Matthias J. Sax created KAFKA-8059: -- Summary: Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota Key: KAFKA-8059 URL: https://issues.apache.org/jira/browse/KAFKA-8059 Project: Kafka

[jira] [Resolved] (KAFKA-8006) Guard calls to init() and close() within user code

[ https://issues.apache.org/jira/browse/KAFKA-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8006. Resolution: Fixed Assignee: Sophie Blee-Goldman Fix Version/s: 2.3.0 >

[jira] [Created] (KAFKA-8055) Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest

Matthias J. Sax created KAFKA-8055: -- Summary: Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest Key: KAFKA-8055 URL: https://issues.apache.org/jira/browse/KAFKA-8055 Project: Kafka

[jira] [Created] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

Matthias J. Sax created KAFKA-8041: -- Summary: Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll Key: KAFKA-8041 URL: https://issues.apache.org/jira/browse/KAFKA-8041 Project: Kafka

[jira] [Created] (KAFKA-8039) Flaky Test SaslAuthenticatorTest#testCannotReauthenticateAgainFasterThanOneSecond

Matthias J. Sax created KAFKA-8039: -- Summary: Flaky Test SaslAuthenticatorTest#testCannotReauthenticateAgainFasterThanOneSecond Key: KAFKA-8039 URL: https://issues.apache.org/jira/browse/KAFKA-8039

[jira] [Created] (KAFKA-8038) Flaky Test SslTransportLayerTest#testCloseSsl

Matthias J. Sax created KAFKA-8038: -- Summary: Flaky Test SslTransportLayerTest#testCloseSsl Key: KAFKA-8038 URL: https://issues.apache.org/jira/browse/KAFKA-8038 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8037) KTable restore may load bad data

Matthias J. Sax created KAFKA-8037: -- Summary: KTable restore may load bad data Key: KAFKA-8037 URL: https://issues.apache.org/jira/browse/KAFKA-8037 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8033) Flaky Test PlaintextConsumerTest#testFetchInvalidOffset

Matthias J. Sax created KAFKA-8033: -- Summary: Flaky Test PlaintextConsumerTest#testFetchInvalidOffset Key: KAFKA-8033 URL: https://issues.apache.org/jira/browse/KAFKA-8033 Project: Kafka

[jira] [Created] (KAFKA-8031) Flaky Test UserClientIdQuotaTest#testQuotaOverrideDelete

Matthias J. Sax created KAFKA-8031: -- Summary: Flaky Test UserClientIdQuotaTest#testQuotaOverrideDelete Key: KAFKA-8031 URL: https://issues.apache.org/jira/browse/KAFKA-8031 Project: Kafka

[jira] [Created] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete

Matthias J. Sax created KAFKA-8032: -- Summary: Flaky Test UserQuotaTest#testQuotaOverrideDelete Key: KAFKA-8032 URL: https://issues.apache.org/jira/browse/KAFKA-8032 Project: Kafka Issue

[jira] [Created] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

Matthias J. Sax created KAFKA-8030: -- Summary: Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed Key: KAFKA-8030 URL: https://issues.apache.org/jira/browse/KAFKA-8030

[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-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] [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-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] [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-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] [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-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] [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] [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] [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] [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-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] [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-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-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] [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] [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-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] [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-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] [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] [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-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] [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-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] [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] [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] [Reopened] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3246: Happend again:

[jira] [Created] (KAFKA-8022) Flaky Test RequestQuotaTest#testExemptRequestTime

Matthias J. Sax created KAFKA-8022: -- Summary: Flaky Test RequestQuotaTest#testExemptRequestTime Key: KAFKA-8022 URL: https://issues.apache.org/jira/browse/KAFKA-8022 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6904. Resolution: Duplicate > DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is

[jira] [Resolved] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7541. Resolution: Duplicate Fix Version/s: (was: 2.2.1) (was:

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

[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7288: Seems not to be fixed:

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

Matthias J. Sax created KAFKA-8018: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed Key: KAFKA-8018 URL: https://issues.apache.org/jira/browse/KAFKA-8018

[jira] [Created] (KAFKA-8015) Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl

Matthias J. Sax created KAFKA-8015: -- Summary: Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl Key: KAFKA-8015 URL:

[jira] [Resolved] (KAFKA-7936) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7936. Resolution: Duplicate > Flaky Test >

[jira] [Created] (KAFKA-8006) Guard calls to init() and close() within user code

Matthias J. Sax created KAFKA-8006: -- Summary: Guard calls to init() and close() within user code Key: KAFKA-8006 URL: https://issues.apache.org/jira/browse/KAFKA-8006 Project: Kafka Issue

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

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7937: Happened again on `trunk`:

[jira] [Created] (KAFKA-8005) Flaky Test ServerShutdownTest#testCleanShutdownAfterFailedStartupDueToCorruptLogs

Matthias J. Sax created KAFKA-8005: -- Summary: Flaky Test ServerShutdownTest#testCleanShutdownAfterFailedStartupDueToCorruptLogs Key: KAFKA-8005 URL: https://issues.apache.org/jira/browse/KAFKA-8005

[jira] [Created] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

Matthias J. Sax created KAFKA-8003: -- Summary: Flaky Test TransactionsTest #testFencingOnTransactionExpiration Key: KAFKA-8003 URL: https://issues.apache.org/jira/browse/KAFKA-8003 Project: Kafka

[jira] [Created] (KAFKA-7999) Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector

Matthias J. Sax created KAFKA-7999: -- Summary: Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector Key: KAFKA-7999 URL: https://issues.apache.org/jira/browse/KAFKA-7999 Project:

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

Matthias J. Sax created KAFKA-7994: -- Summary: Improve Stream-Time for rebalances and restarts Key: KAFKA-7994 URL: https://issues.apache.org/jira/browse/KAFKA-7994 Project: Kafka Issue

[jira] [Created] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

Matthias J. Sax created KAFKA-7991: -- Summary: Add StreamsUpgradeTest for 2.2 release Key: KAFKA-7991 URL: https://issues.apache.org/jira/browse/KAFKA-7991 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

Matthias J. Sax created KAFKA-7990: -- Summary: Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs Key: KAFKA-7990 URL: https://issues.apache.org/jira/browse/KAFKA-7990 Project: Kafka

[jira] [Resolved] (KAFKA-7938) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdWithShortInitialization

[ https://issues.apache.org/jira/browse/KAFKA-7938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7938. Resolution: Fixed > Flaky Test

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

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7937. Resolution: Fixed > Flaky Test

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

Matthias J. Sax created KAFKA-7989: -- Summary: Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated Key: KAFKA-7989 URL: https://issues.apache.org/jira/browse/KAFKA-7989

[jira] [Created] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

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

[jira] [Created] (KAFKA-7980) Flaky Test SocketServerTest#testConnectionRateLimit

Matthias J. Sax created KAFKA-7980: -- Summary: Flaky Test SocketServerTest#testConnectionRateLimit Key: KAFKA-7980 URL: https://issues.apache.org/jira/browse/KAFKA-7980 Project: Kafka Issue

[jira] [Created] (KAFKA-7979) Flaky Test PartitionTest#testDelayedFetchAfterAppendRecords

Matthias J. Sax created KAFKA-7979: -- Summary: Flaky Test PartitionTest#testDelayedFetchAfterAppendRecords Key: KAFKA-7979 URL: https://issues.apache.org/jira/browse/KAFKA-7979 Project: Kafka

[jira] [Created] (KAFKA-7978) Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

Matthias J. Sax created KAFKA-7978: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups Key: KAFKA-7978 URL: https://issues.apache.org/jira/browse/KAFKA-7978 Project: Kafka

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

Matthias J. Sax created KAFKA-7977: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldOnlyThrottleMovingReplicas Key: KAFKA-7977 URL: https://issues.apache.org/jira/browse/KAFKA-7977 Project:

[jira] [Created] (KAFKA-7976) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

Matthias J. Sax created KAFKA-7976: -- Summary: Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable Key: KAFKA-7976 URL: https://issues.apache.org/jira/browse/KAFKA-7976

[jira] [Resolved] (KAFKA-5510) Streams should commit all offsets regularly

[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5510. Resolution: Won't Do > Streams should commit all offsets regularly >

[jira] [Created] (KAFKA-7973) Allow a Punctuator to cancel its own schedule

Matthias J. Sax created KAFKA-7973: -- Summary: Allow a Punctuator to cancel its own schedule Key: KAFKA-7973 URL: https://issues.apache.org/jira/browse/KAFKA-7973 Project: Kafka Issue Type:

<    3   4   5   6   7   8   9   10   11   12   >