[jira] [Resolved] (KAFKA-6888) java.lang.UnsatisfiedLinkError: librocksdbjni4271925274440341234.dll: âÑX

[ https://issues.apache.org/jira/browse/KAFKA-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6888. Resolution: Abandoned > java.lang.UnsatisfiedLinkError: librocksdbjni4271925274440341234.dl

[jira] [Resolved] (KAFKA-6822) Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6822. Resolution: Abandoned > Kafka Consumer 0.10.2.1 can not normally read data from Kafka 1.0.0

[jira] [Resolved] (KAFKA-6821) The producer attempted to use a producer id which is not currently assigned to its transactional id

[ https://issues.apache.org/jira/browse/KAFKA-6821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6821. Resolution: Cannot Reproduce A lot of work on EOS was done recently. Closing this ticket at

[jira] [Resolved] (KAFKA-6804) Event values should not be included in log messages

[ https://issues.apache.org/jira/browse/KAFKA-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6804. Resolution: Fixed I believe this is fixed via KAFKA-8501. > Event values should not be inc

[jira] [Resolved] (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 resolved KAFKA-6461. Resolution: Cannot Reproduce > TableTableJoinIntegrationTest is unstable if caching is enab

[jira] [Resolved] (KAFKA-6237) stream stopped working after exception: Cannot execute transactional method because we are in an error state

[ https://issues.apache.org/jira/browse/KAFKA-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6237. Resolution: Cannot Reproduce There was a lot of EOS work recently. Closing this ticket. Sho

[jira] [Resolved] (KAFKA-6182) Automatic co-partitioning of topics via automatic intermediate topic with matching partitions

[ https://issues.apache.org/jira/browse/KAFKA-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6182. Resolution: Fixed KIP-221 is implemented now. Closing this ticket. > Automatic co-partitio

[jira] [Resolved] (KAFKA-6125) Avoid third party exception to flow through streams code base

[ https://issues.apache.org/jira/browse/KAFKA-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6125. Resolution: Not A Problem > Avoid third party exception to flow through streams code base >

[jira] [Resolved] (KAFKA-6124) Revisit default config for internal client with regard to resilience

[ https://issues.apache.org/jira/browse/KAFKA-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6124. Resolution: Abandoned We changed couple of default values (also in consumer/producer/admin

[jira] [Resolved] (KAFKA-6000) streams 0.10.2.1 - kafka 0.11.0.1 state restore not working

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6000. Resolution: Abandoned > streams 0.10.2.1 - kafka 0.11.0.1 state restore not working > -

[jira] [Resolved] (KAFKA-5625) Invalid subscription data may cause streams app to throw BufferUnderflowException

[ https://issues.apache.org/jira/browse/KAFKA-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5625. Resolution: Abandoned > Invalid subscription data may cause streams app to throw > BufferU

[jira] [Resolved] (KAFKA-5581) Avoid creating changelog topics for state stores that are materialized from a source topic

[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5581. Resolution: Fixed > Avoid creating changelog topics for state stores that are materialized

[jira] [Resolved] (KAFKA-5393) in-memory state store memory issue

[ https://issues.apache.org/jira/browse/KAFKA-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5393. Resolution: Abandoned > in-memory state store memory issue > -

[jira] [Resolved] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5240. Resolution: Fixed > Make persistent checkpointedOffsets optionable > --

[jira] [Resolved] (KAFKA-5071) ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.errors.ProcessorStateExcept

[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5071. Resolution: Abandoned > ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThre

[jira] [Resolved] (KAFKA-4934) Add streams test with RocksDb failures

[ https://issues.apache.org/jira/browse/KAFKA-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4934. Resolution: Abandoned > Add streams test with RocksDb failures > --

[jira] [Resolved] (KAFKA-4887) Enabling caching on a persistent window store breaks support for duplicate insertion

[ https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4887. Resolution: Fixed > Enabling caching on a persistent window store breaks support for duplic

[jira] [Resolved] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes

[ https://issues.apache.org/jira/browse/KAFKA-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4778. Resolution: Abandoned Does not seem to be an issue in newer released any more? > OOM on ka

[jira] [Resolved] (KAFKA-4742) ResetTool does not commit offsets correclty

[ https://issues.apache.org/jira/browse/KAFKA-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4742. Resolution: Abandoned This ticket only affect 0.10.0.x and 0.10.1.x and it's very unlikely

[jira] [Resolved] (KAFKA-4697) Simplify Streams Reset Tool

[ https://issues.apache.org/jira/browse/KAFKA-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4697. Resolution: Abandoned This tickets only affect 0.10.0.x and 0.10.1.x versions and it's very

[jira] [Resolved] (KAFKA-3779) Add the LRU cache for KTable.to() operator

[ https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3779. Resolution: Won't Fix `KTable#to()` was removed from the API. > Add the LRU cache for KTab

[jira] [Resolved] (KAFKA-10) Kafka deployment on EC2 should be WHIRR based, instead of current contrib/deploy code based solution

[ https://issues.apache.org/jira/browse/KAFKA-10?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10. -- Resolution: Won't Fix (was: Abandoned) Apache Whirr has been retired. > Kafka deployment on EC2

[jira] [Resolved] (KAFKA-9984) Should fail the subscription when pattern is empty

[ https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9984. Fix Version/s: 2.6.0 Resolution: Fixed > Should fail the subscription when pattern i

[jira] [Resolved] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

[ https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9850. Fix Version/s: 2.6.0 Resolution: Fixed > Move KStream#repartition operator validatio

[jira] [Resolved] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9465. Resolution: Not A Problem This was fixed implicitly via some code refactoring. > Enclose c

[jira] [Resolved] (KAFKA-9966) Flaky Test EosBetaUpgradeIntegrationTest#shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9966. Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test EosBetaUpgradeIntegrationTest#sh

[jira] [Resolved] (KAFKA-9949) Flaky Test GlobalKTableIntegrationTest#shouldKStreamGlobalKTableLeftJoin

[ https://issues.apache.org/jira/browse/KAFKA-9949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9949. Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test GlobalKTableIntegrationTest#shou

[jira] [Resolved] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9972. Fix Version/s: 2.6.0 Resolution: Fixed > Corrupted standby task could be committed >

[jira] [Created] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

Matthias J. Sax created KAFKA-9974: -- Summary: Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore Key: KAFKA-9974 URL: https://issues.apache.org/jira/browse/KAFKA-9974 Project:

[jira] [Resolved] (KAFKA-9290) Update IQ related JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9290. Fix Version/s: 2.6.0 Resolution: Fixed > Update IQ related JavaDocs > --

[jira] [Created] (KAFKA-9966) Flaky Test EosBetaUpgradeIntegrationTest#shouldUpgradeFromEosAlphaToEosBeta

Matthias J. Sax created KAFKA-9966: -- Summary: Flaky Test EosBetaUpgradeIntegrationTest#shouldUpgradeFromEosAlphaToEosBeta Key: KAFKA-9966 URL: https://issues.apache.org/jira/browse/KAFKA-9966 Project

[jira] [Created] (KAFKA-9949) Flaky Test GlobalKTableIntegrationTest#shouldKStreamGlobalKTableLeftJoin

Matthias J. Sax created KAFKA-9949: -- Summary: Flaky Test GlobalKTableIntegrationTest#shouldKStreamGlobalKTableLeftJoin Key: KAFKA-9949 URL: https://issues.apache.org/jira/browse/KAFKA-9949 Project: K

[jira] [Reopened] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8940: Reopening. Failed again: [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/231/testRepor

[jira] [Resolved] (KAFKA-9896) Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta]

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

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

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

[jira] [Created] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

Matthias J. Sax created KAFKA-9913: -- Summary: TopologyDescription should expose all topic name progrematically Key: KAFKA-9913 URL: https://issues.apache.org/jira/browse/KAFKA-9913 Project: Kafka

[jira] [Created] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

Matthias J. Sax created KAFKA-9897: -- Summary: Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores Key: KAFKA-9897 URL: https://issues.apache.org/jira/browse/KAFKA-9897 Proje

[jira] [Created] (KAFKA-9896) Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta]

Matthias J. Sax created KAFKA-9896: -- Summary: Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta] Key: KAFKA-9896 URL: https://issues.apache.org/jira/browse/KAFKA-9896

[jira] [Resolved] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9243. Resolution: Duplicate Closing is ticket in favor of KAFKA-9290. > Update the javadocs from

[jira] [Resolved] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

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

[jira] [Resolved] (KAFKA-9819) Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]

[ https://issues.apache.org/jira/browse/KAFKA-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9819. Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test StoreChangelogReaderTest#shouldN

[jira] [Resolved] (KAFKA-9779) Add version 2.5 to streams system tests

[ https://issues.apache.org/jira/browse/KAFKA-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9779. Fix Version/s: 2.6.0 Resolution: Fixed > Add version 2.5 to streams system tests > -

[jira] [Reopened] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5676: > MockStreamsMetrics should be in o.a.k.test > -- > >

[jira] [Resolved] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5676. Resolution: Fixed > MockStreamsMetrics should be in o.a.k.test > --

[jira] [Resolved] (KAFKA-7544) Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails

[ https://issues.apache.org/jira/browse/KAFKA-7544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7544. Resolution: Duplicate Closing this ticket as it links to the older, non-parameterized versi

[jira] [Resolved] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9859. Resolution: Not A Problem > kafka-streams-application-reset tool doesn't take into account

[jira] [Resolved] (KAFKA-6910) Ability to specify a default state store type or factory

[ https://issues.apache.org/jira/browse/KAFKA-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6910. Resolution: Duplicate > Ability to specify a default state store type or factory >

[jira] [Resolved] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6037. Resolution: Fixed Closing is as "fixed by KAFKA-8611". > Make Sub-topology Parallelism Tun

[jira] [Resolved] (KAFKA-8611) Add KStream#repartition operation

[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8611. Resolution: Fixed > Add KStream#repartition operation > - >

[jira] [Created] (KAFKA-9847) Add config to set default store type

Matthias J. Sax created KAFKA-9847: -- Summary: Add config to set default store type Key: KAFKA-9847 URL: https://issues.apache.org/jira/browse/KAFKA-9847 Project: Kafka Issue Type: Improvemen

[jira] [Reopened] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9187: This test failed again with a different error message ([https://builds.apache.org/job/kafka-pr

[jira] [Created] (KAFKA-9832) Extend EOS system tests for EOS-beta

Matthias J. Sax created KAFKA-9832: -- Summary: Extend EOS system tests for EOS-beta Key: KAFKA-9832 URL: https://issues.apache.org/jira/browse/KAFKA-9832 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9812. Fix Version/s: 2.6.0 Resolution: Fixed > Integration tests hang and timeout the enti

[jira] [Created] (KAFKA-9799) Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsToLatest

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

[jira] [Resolved] (KAFKA-9759) Add documentation change for KIP-562

[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9759. Fix Version/s: 2.5.0 Resolution: Fixed > Add documentation change for KIP-562 >

[jira] [Created] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

Matthias J. Sax created KAFKA-9783: -- Summary: Flaky Test QueryableStateIntegrationTest#concurrentAccesses Key: KAFKA-9783 URL: https://issues.apache.org/jira/browse/KAFKA-9783 Project: Kafka

[jira] [Created] (KAFKA-9776) Producer should automatically downgrade CommitTxRequest

Matthias J. Sax created KAFKA-9776: -- Summary: Producer should automatically downgrade CommitTxRequest Key: KAFKA-9776 URL: https://issues.apache.org/jira/browse/KAFKA-9776 Project: Kafka Iss

[jira] [Resolved] (KAFKA-9760) Add EOS protocol changes to documentation

[ https://issues.apache.org/jira/browse/KAFKA-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9760. Fix Version/s: 2.6.0 Resolution: Fixed > Add EOS protocol changes to documentation >

[jira] [Resolved] (KAFKA-9758) Add documentations for KIP-523 and KIP-527

[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9758. Fix Version/s: 2.5.0 Resolution: Fixed > Add documentations for KIP-523 and KIP-527

[jira] [Resolved] (KAFKA-9736) Use internal consumer config to fail for unsupported protocol

[ https://issues.apache.org/jira/browse/KAFKA-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9736. Resolution: Duplicate > Use internal consumer config to fail for unsupported protocol > ---

[jira] [Created] (KAFKA-9748) Extend EOS integration test for EOS-beta

Matthias J. Sax created KAFKA-9748: -- Summary: Extend EOS integration test for EOS-beta Key: KAFKA-9748 URL: https://issues.apache.org/jira/browse/KAFKA-9748 Project: Kafka Issue Type: Sub-ta

[jira] [Created] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

Matthias J. Sax created KAFKA-9741: -- Summary: ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked() Key: KAFKA-9741 URL: https://issues.apache.org/jira/browse/KAFKA-9741

[jira] [Created] (KAFKA-9736) Use internal consumer config to fail for unsupported protocol

Matthias J. Sax created KAFKA-9736: -- Summary: Use internal consumer config to fail for unsupported protocol Key: KAFKA-9736 URL: https://issues.apache.org/jira/browse/KAFKA-9736 Project: Kafka

[jira] [Resolved] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9441. Fix Version/s: 2.6.0 Resolution: Fixed > Refactor commit logic > ---

[jira] [Created] (KAFKA-9714) Flaky Test SslTransportLayerTest#testTLSDefaults

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

[jira] [Resolved] (KAFKA-9682) Flaky Test KafkaBasedLogTest#testSendAndReadToEnd

[ https://issues.apache.org/jira/browse/KAFKA-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9682. Resolution: Fixed Closing this as "fixed by" KAFKA-9686 > Flaky Test KafkaBasedLogTest#tes

[jira] [Resolved] (KAFKA-9686) MockConsumer#endOffsets should be idempotent

[ https://issues.apache.org/jira/browse/KAFKA-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9686. Resolution: Fixed > MockConsumer#endOffsets should be idempotent >

[jira] [Resolved] (KAFKA-8019) Better Scaling Experience for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8019. Resolution: Duplicate Closing this a duplicate of KAFKA-6145. Should be address via KIP-441

[jira] [Created] (KAFKA-9682) Flaky Test KafkaBasedLogTest#testSendAndReadToEnd

Matthias J. Sax created KAFKA-9682: -- Summary: Flaky Test KafkaBasedLogTest#testSendAndReadToEnd Key: KAFKA-9682 URL: https://issues.apache.org/jira/browse/KAFKA-9682 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

[ https://issues.apache.org/jira/browse/KAFKA-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9240. Resolution: Duplicate Closing this as duplicate. > Flaky test > kafka.admin.ReassignParti

[jira] [Created] (KAFKA-9655) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe

Matthias J. Sax created KAFKA-9655: -- Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-9655 URL: https://issues.apache.org/jira/browse/KAFKA-9655

[jira] [Created] (KAFKA-9597) Flaky Test KafkaProducerTest#testInitTransactionTimeout

Matthias J. Sax created KAFKA-9597: -- Summary: Flaky Test KafkaProducerTest#testInitTransactionTimeout Key: KAFKA-9597 URL: https://issues.apache.org/jira/browse/KAFKA-9597 Project: Kafka Iss

[jira] [Reopened] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9441: The first PR was just part of this ticket. We still need to change the commit logic for eos-be

[jira] [Resolved] (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 resolved KAFKA-8025. Resolution: Fixed > Flaky Test > RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapte

[jira] [Resolved] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6607. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams lag not zero when input topic

[jira] [Resolved] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9483. Fix Version/s: 2.5.0 Resolution: Fixed > Add Scala KStream#toTable to the Streams DS

[jira] [Resolved] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

[ https://issues.apache.org/jira/browse/KAFKA-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9248. Resolution: Duplicate Agreed. Closing this ticket as duplicate. > Foreign key join does no

[jira] [Resolved] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8940. Resolution: Fixed Nevermind. The test is fine. The PR broke the test. Can reproduce it loca

[jira] [Created] (KAFKA-9516) Flaky Test PlaintextProducerSendTest#testNonBlockingProducer

Matthias J. Sax created KAFKA-9516: -- Summary: Flaky Test PlaintextProducerSendTest#testNonBlockingProducer Key: KAFKA-9516 URL: https://issues.apache.org/jira/browse/KAFKA-9516 Project: Kafka

[jira] [Reopened] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8940: Reopening. Failed again:  [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4521/testRepo

[jira] [Created] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

Matthias J. Sax created KAFKA-9512: -- Summary: Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration Key: KAFKA-9512 URL: https://issues.apache.org/jira/browse/KAFKA-9512 Project: Kafka

[jira] [Created] (KAFKA-9502) Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config

Matthias J. Sax created KAFKA-9502: -- Summary: Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config Key: KAFKA-9502 URL: https://issues.apache.org/jira/browse/KAFKA-9502

[jira] [Created] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

Matthias J. Sax created KAFKA-9501: -- Summary: Promote Standby tasks to active tasks without closing them Key: KAFKA-9501 URL: https://issues.apache.org/jira/browse/KAFKA-9501 Project: Kafka

[jira] [Created] (KAFKA-9496) Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

Matthias J. Sax created KAFKA-9496: -- Summary: Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9496 URL: https://issues.apache.org/jira/browse/KAFKA-9496

[jira] [Created] (KAFKA-9495) Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk

Matthias J. Sax created KAFKA-9495: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk Key: KAFKA-9495 URL: https://issues.apache.org/jira/browse/KAFKA-9495 Proje

[jira] [Resolved] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7658. Fix Version/s: 2.5.0 Resolution: Fixed > Add KStream#toTable to the Streams DSL > --

[jira] [Resolved] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9445. Fix Version/s: 2.5.0 Resolution: Fixed > Allow fetching a key from a single partitio

[jira] [Resolved] (KAFKA-8317) ClassCastException using KTable.suppress()

[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8317. Resolution: Duplicate Closing this ticket in favor of KAFKA-9259 that duplicates it. > Cla

[jira] [Created] (KAFKA-9451) Pass consumer group metadata to producer on commit

Matthias J. Sax created KAFKA-9451: -- Summary: Pass consumer group metadata to producer on commit Key: KAFKA-9451 URL: https://issues.apache.org/jira/browse/KAFKA-9451 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-9441) Refactor commit logic

Matthias J. Sax created KAFKA-9441: -- Summary: Refactor commit logic Key: KAFKA-9441 URL: https://issues.apache.org/jira/browse/KAFKA-9441 Project: Kafka Issue Type: Sub-task Compon

[jira] [Reopened] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8677: Reopening this ticket. Test failed again:  [https://builds.apache.org/job/kafka-pr-jdk11-scala2

[jira] [Created] (KAFKA-9399) Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild

Matthias J. Sax created KAFKA-9399: -- Summary: Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild Key: KAFKA-9399 URL: https://issues.apache.org/jira/browse/KAFKA-9399 Pro

[jira] [Resolved] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6571. Resolution: Duplicate KIP-367 add `close(Duration)` with new non-blocking semantics:  [http

[jira] [Resolved] (KAFKA-9383) Expose Consumer Group Metadata for Transactional Producer

[ https://issues.apache.org/jira/browse/KAFKA-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9383. Fix Version/s: 2.5.0 Resolution: Fixed > Expose Consumer Group Metadata for Transact

[jira] [Resolved] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9068. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution: Fi

[jira] [Resolved] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6049. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams: Add Cogroup in the DSL > ---

[jira] [Created] (KAFKA-9388) Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables

Matthias J. Sax created KAFKA-9388: -- Summary: Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables Key: KAFKA-9388 URL: https://issues.apache.org/jira/brow

[jira] [Resolved] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6614. Fix Version/s: 2.5.0 Resolution: Fixed > kafka-streams to configure internal topics

[jira] [Created] (KAFKA-9379) Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware

Matthias J. Sax created KAFKA-9379: -- Summary: Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware Key: KAFKA-9379 URL: https://issues.apache.org/jira/browse/KAFKA-9379 Projec

[jira] [Resolved] (KAFKA-9334) Add more unit tests for Materialized class

[ https://issues.apache.org/jira/browse/KAFKA-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9334. Fix Version/s: 2.5.0 Resolution: Fixed > Add more unit tests for Materialized class

<    1   2   3   4   5   6   7   8   9   10   >