[jira] [Resolved] (KAFKA-11200) Load Bug greeqrsThe 3

[ https://issues.apache.org/jira/browse/KAFKA-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11200. - Resolution: Invalid > Load Bug greeqrsThe 3 > -- > >

[jira] [Resolved] (KAFKA-11205) Load Bug greeqrsThe 10

[ https://issues.apache.org/jira/browse/KAFKA-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11205. - Resolution: Invalid > Load Bug greeqrsThe 10 > --- > >

[jira] [Resolved] (KAFKA-11213) Load Bug itbe 15

[ https://issues.apache.org/jira/browse/KAFKA-11213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11213. - Resolution: Invalid > Load Bug itbe 15 > - > > Key:

[jira] [Resolved] (KAFKA-11215) Load Bug eqrsTheret 1

[ https://issues.apache.org/jira/browse/KAFKA-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11215. - Resolution: Invalid > Load Bug eqrsTheret 1 > -- > >

[jira] [Resolved] (KAFKA-11214) Load Bug zananswerl 11

[ https://issues.apache.org/jira/browse/KAFKA-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11214. - Resolution: Invalid > Load Bug zananswerl 11 > --- > >

[jira] [Resolved] (KAFKA-11212) Load Bug ivingefgin 19

[ https://issues.apache.org/jira/browse/KAFKA-11212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-11212. - Resolution: Invalid > Load Bug ivingefgin 19 > --- > >

[jira] [Resolved] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10722. - Fix Version/s: 2.8.0 Resolution: Fixed Added you to the list of contributors and

[jira] [Resolved] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

[ https://issues.apache.org/jira/browse/KAFKA-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8651. Resolution: Duplicate Closing this ticket in favor of KAFKA-5488 that is backed by KIP-418

[jira] [Created] (KAFKA-10848) Allow fine grained control over cross-partition processing order

Matthias J. Sax created KAFKA-10848: --- Summary: Allow fine grained control over cross-partition processing order Key: KAFKA-10848 URL: https://issues.apache.org/jira/browse/KAFKA-10848 Project:

[jira] [Created] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

Matthias J. Sax created KAFKA-10847: --- Summary: Avoid spurious left/outer join results in stream-stream join Key: KAFKA-10847 URL: https://issues.apache.org/jira/browse/KAFKA-10847 Project: Kafka

[jira] [Resolved] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9552. Fix Version/s: 2.6.0 Resolution: Fixed > Stream should handle OutOfSequence

[jira] [Reopened] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9552: > Stream should handle OutOfSequence exception thrown from Producer >

[jira] [Resolved] (KAFKA-10752) One topic partition multiple consumer

[ https://issues.apache.org/jira/browse/KAFKA-10752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10752. - Resolution: Invalid [~dnamicro] – we use the Jira board for bug reports, not to answer

[jira] [Resolved] (KAFKA-10745) Please let me know how I check the time which Source connector receive the data from source table.

[ https://issues.apache.org/jira/browse/KAFKA-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10745. - Resolution: Invalid [~nayusik] – we use the Jira board for bug reports, not to answer

[jira] [Created] (KAFKA-10755) Should consider commit latency when computing next commit timestamp

Matthias J. Sax created KAFKA-10755: --- Summary: Should consider commit latency when computing next commit timestamp Key: KAFKA-10755 URL: https://issues.apache.org/jira/browse/KAFKA-10755 Project:

[jira] [Resolved] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10500. - Fix Version/s: 2.8.0 Resolution: Fixed > Add API to Start and Stop Stream

[jira] [Resolved] (KAFKA-10036) Improve error message if user violates `Supplier` pattern

[ https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10036. - Fix Version/s: 2.8.0 Resolution: Fixed > Improve error message if user violates

[jira] [Resolved] (KAFKA-10569) Running aggregate queries on KSQL client side is getting to ERROR Shutdown broker because all log dirs in ...

[ https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10569. - Resolution: Invalid > Running aggregate queries on KSQL client side is getting to ERROR

[jira] [Resolved] (KAFKA-6585) Consolidate duplicated logic on reset tools

[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6585. Fix Version/s: 2.7.0 Resolution: Fixed > Consolidate duplicated logic on reset

[jira] [Created] (KAFKA-10555) Improve client state machine

Matthias J. Sax created KAFKA-10555: --- Summary: Improve client state machine Key: KAFKA-10555 URL: https://issues.apache.org/jira/browse/KAFKA-10555 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-10297) Don't use deprecated producer config `retries`

[ https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10297. - Resolution: Invalid We change the KIP to not deprecate `retries`. Hence, this ticket is

[jira] [Resolved] (KAFKA-10480) Kafka streams application is being stuck

[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10480. - Resolution: Invalid > Kafka streams application is being stuck >

[jira] [Reopened] (KAFKA-10480) Kafka streams application is being stuck

[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10480: - > Kafka streams application is being stuck > > >

[jira] [Created] (KAFKA-10351) Add missing tests for IOExceptions for GlobalStateManagerImpl

Matthias J. Sax created KAFKA-10351: --- Summary: Add missing tests for IOExceptions for GlobalStateManagerImpl Key: KAFKA-10351 URL: https://issues.apache.org/jira/browse/KAFKA-10351 Project: Kafka

[jira] [Resolved] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11

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

[jira] [Created] (KAFKA-10317) Global thread should honor shutdown signal during bootstrapping

Matthias J. Sax created KAFKA-10317: --- Summary: Global thread should honor shutdown signal during bootstrapping Key: KAFKA-10317 URL: https://issues.apache.org/jira/browse/KAFKA-10317 Project: Kafka

[jira] [Created] (KAFKA-10316) Consider renaming getter method for Interactive Queries

Matthias J. Sax created KAFKA-10316: --- Summary: Consider renaming getter method for Interactive Queries Key: KAFKA-10316 URL: https://issues.apache.org/jira/browse/KAFKA-10316 Project: Kafka

[jira] [Created] (KAFKA-10315) Consider to throw exception for failed fetch requests

Matthias J. Sax created KAFKA-10315: --- Summary: Consider to throw exception for failed fetch requests Key: KAFKA-10315 URL: https://issues.apache.org/jira/browse/KAFKA-10315 Project: Kafka

[jira] [Created] (KAFKA-10306) GlobalThread might loop forever

Matthias J. Sax created KAFKA-10306: --- Summary: GlobalThread might loop forever Key: KAFKA-10306 URL: https://issues.apache.org/jira/browse/KAFKA-10306 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-10297) Don't use deprecated producer config `retries`

Matthias J. Sax created KAFKA-10297: --- Summary: Don't use deprecated producer config `retries` Key: KAFKA-10297 URL: https://issues.apache.org/jira/browse/KAFKA-10297 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8296) Kafka Streams branch method raises type warnings

[ https://issues.apache.org/jira/browse/KAFKA-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8296. Resolution: Duplicate Closing this ticket as duplicate. > Kafka Streams branch method

[jira] [Created] (KAFKA-10277) Relax non-null key requirement for stream-globalTable joins

Matthias J. Sax created KAFKA-10277: --- Summary: Relax non-null key requirement for stream-globalTable joins Key: KAFKA-10277 URL: https://issues.apache.org/jira/browse/KAFKA-10277 Project: Kafka

[jira] [Resolved] (KAFKA-10247) Streams may attempt to process after closing a task

[ https://issues.apache.org/jira/browse/KAFKA-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10247. - Fix Version/s: 2.6.0 Resolution: Fixed > Streams may attempt to process after

[jira] [Resolved] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10262. - Fix Version/s: 2.6.0 Resolution: Fixed > StateDirectory is not thread-safe >

[jira] [Resolved] (KAFKA-10222) Incorrect methods show up in 0.10 Kafka Streams docs

[ https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10222. - Resolution: Fixed > Incorrect methods show up in 0.10 Kafka Streams docs >

[jira] [Reopened] (KAFKA-6453) Reconsider timestamp propagation semantics

[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6453: IMHO, the PR only covers part of this ticket. We should also document how timestamps are

[jira] [Resolved] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9891. Resolution: Fixed > Invalid state store content after task migration with exactly_once and

[jira] [Resolved] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

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

[jira] [Created] (KAFKA-10168) Rename public StreamsConfig variable

Matthias J. Sax created KAFKA-10168: --- Summary: Rename public StreamsConfig variable Key: KAFKA-10168 URL: https://issues.apache.org/jira/browse/KAFKA-10168 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

[ https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7833. Fix Version/s: 2.6.0 Resolution: Fixed > StreamsBuilder should throw an exception

[jira] [Resolved] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7608. Resolution: Fixed KIP-221 is merged. Closing this ticket. > A Kafka Streams DSL transform

[jira] [Resolved] (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 resolved KAFKA-8011. Assignee: Matthias J. Sax (was: Sophie Blee-Goldman) Resolution: Fixed The

[jira] [Resolved] (KAFKA-10030) Throw exception while fetching a key from a single partition

[ https://issues.apache.org/jira/browse/KAFKA-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10030. - Resolution: Fixed > Throw exception while fetching a key from a single partition >

[jira] [Resolved] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10064. - Resolution: Fixed > Add documentation for KIP-571 > - > >

[jira] [Created] (KAFKA-10055) Add shared internal utility class

Matthias J. Sax created KAFKA-10055: --- Summary: Add shared internal utility class Key: KAFKA-10055 URL: https://issues.apache.org/jira/browse/KAFKA-10055 Project: Kafka Issue Type:

[jira] [Reopened] (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 reopened KAFKA-8011: Failed again: 

[jira] [Resolved] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-658. --- Resolution: Fixed Closing this ticket as fixed, as MM2 is available now. > Implement "Exact

[jira] [Resolved] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-617. --- Resolution: Abandoned Closing this old ticket as abandoned. > Refactor

[jira] [Resolved] (KAFKA-205) Audit swallowing of exceptions/throwables

[ https://issues.apache.org/jira/browse/KAFKA-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-205. --- Resolution: Abandoned Closing this old ticket as abandoned. > Audit swallowing of

[jira] [Resolved] (KAFKA-72) Redo config objects with default arguments

[ https://issues.apache.org/jira/browse/KAFKA-72?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-72. -- Closing this old ticket as abandoned. > Redo config objects with default arguments >

[jira] [Resolved] (KAFKA-40) Time based log rolling

[ https://issues.apache.org/jira/browse/KAFKA-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-40. -- Resolution: Implemented (was: Abandoned) It seem the time-index as introduced via KIP-33

[jira] [Resolved] (KAFKA-39) javaapi does not declare IOException to be thrown

[ https://issues.apache.org/jira/browse/KAFKA-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-39. -- > javaapi does not declare IOException to be thrown >

[jira] [Created] (KAFKA-10036) Improve error message is user violates `Supplier` pattern

Matthias J. Sax created KAFKA-10036: --- Summary: Improve error message is user violates `Supplier` pattern Key: KAFKA-10036 URL: https://issues.apache.org/jira/browse/KAFKA-10036 Project: Kafka

[jira] [Resolved] (KAFKA-10003) Deprecate KStream#through in favor of KStream#repartition

[ https://issues.apache.org/jira/browse/KAFKA-10003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10003. - Fix Version/s: 2.6.0 Resolution: Fixed > Deprecate KStream#through in favor of

[jira] [Resolved] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7041. Resolution: Won't Fix > Using RocksDB bulk loading for StandbyTasks >

[jira] [Resolved] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8311. Resolution: Duplicate Closing this ticket – KIP-572 / KAFKA-9274 does subsume it. >

[jira] [Resolved] (KAFKA-7985) Cleanup AssignedTasks / AbstractTask logic

[ https://issues.apache.org/jira/browse/KAFKA-7985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7985. Resolution: Abandoned Given that this ticket is old and the code was refactored multiple

[jira] [Resolved] (KAFKA-7708) [kafka-streams-scala] Invalid signature for KTable join in 2.12

[ https://issues.apache.org/jira/browse/KAFKA-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7708. Resolution: Abandoned > [kafka-streams-scala] Invalid signature for KTable join in 2.12 >

[jira] [Resolved] (KAFKA-7445) Branch one Stream in multiple Streams

[ https://issues.apache.org/jira/browse/KAFKA-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7445. Resolution: Not A Problem > Branch one Stream in multiple Streams >

[jira] [Resolved] (KAFKA-7203) Improve Streams StickyTaskAssingor

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

[jira] [Resolved] (KAFKA-7209) Kafka stream does not rebalance when one node gets down

[ https://issues.apache.org/jira/browse/KAFKA-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7209. Resolution: Abandoned > Kafka stream does not rebalance when one node gets down >

[jira] [Resolved] (KAFKA-7133) DisconnectException every 5 minutes in single restore consumer thread

[ https://issues.apache.org/jira/browse/KAFKA-7133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7133. Resolution: Abandoned > DisconnectException every 5 minutes in single restore consumer

[jira] [Resolved] (KAFKA-7035) Kafka Processor's init() method sometimes is not called

[ https://issues.apache.org/jira/browse/KAFKA-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7035. Resolution: Abandoned > Kafka Processor's init() method sometimes is not called >

[jira] [Resolved] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7015. Resolution: Not A Problem We should actually not log sensitive information like key and

[jira] [Resolved] (KAFKA-7004) Support configurable restore consumer poll timeout

[ https://issues.apache.org/jira/browse/KAFKA-7004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7004. Resolution: Fixed > Support configurable restore consumer poll timeout >

[jira] [Resolved] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6977. Resolution: Abandoned > Kafka Streams - java.lang.IllegalStateException: Unexpected error

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

[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

[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

[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

[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

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

[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

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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

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

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

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

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