[jira] [Reopened] (KAFKA-4790) Kafka cannot recover after a disk full

[ https://issues.apache.org/jira/browse/KAFKA-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reopened KAFKA-4790: - > Kafka cannot recover after a disk full > -- > >

[jira] [Resolved] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2

[ https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5571. - Resolution: Fixed > Possible deadlock during shutdown in setState in kafka streams 10.2 >

[jira] [Created] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels

Eno Thereska created KAFKA-5733: --- Summary: System tests get exception RocksDBException: db has more levels than options.num_levels Key: KAFKA-5733 URL: https://issues.apache.org/jira/browse/KAFKA-5733 P

[jira] [Created] (KAFKA-5725) Additional failure testing for streams with bouncing brokers

Eno Thereska created KAFKA-5725: --- Summary: Additional failure testing for streams with bouncing brokers Key: KAFKA-5725 URL: https://issues.apache.org/jira/browse/KAFKA-5725 Project: Kafka Iss

[jira] [Created] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails

Eno Thereska created KAFKA-5701: --- Summary: Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails Key: KAFKA-5701 URL: https://issues.apache.org/jira/browse/KAFKA-5701 Project: Kafka

[jira] [Resolved] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5301. - Resolution: Won't Fix > Improve exception handling on consumer path >

[jira] [Resolved] (KAFKA-5300) Improve exception handling on producer path

[ https://issues.apache.org/jira/browse/KAFKA-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5300. - Resolution: Duplicate Duplicate of KAFKA-5006 > Improve exception handling on producer path > ---

[jira] [Resolved] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5302. - Resolution: Won't Fix > Improve exception handling on streams client (communication with brokers)

[jira] [Resolved] (KAFKA-5217) Improve Streams internal exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5217. - Resolution: Duplicate > Improve Streams internal exception handling >

[jira] [Reopened] (KAFKA-5566) Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reopened KAFKA-5566: - > Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied >

[jira] [Created] (KAFKA-5569) Document any changes from this task

Eno Thereska created KAFKA-5569: --- Summary: Document any changes from this task Key: KAFKA-5569 URL: https://issues.apache.org/jira/browse/KAFKA-5569 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

Eno Thereska created KAFKA-5552: --- Summary: testTransactionalProducerTopicAuthorizationExceptionInCommit fails Key: KAFKA-5552 URL: https://issues.apache.org/jira/browse/KAFKA-5552 Project: Kafka

[jira] [Created] (KAFKA-5533) Timestamp-based log compaction

Eno Thereska created KAFKA-5533: --- Summary: Timestamp-based log compaction Key: KAFKA-5533 URL: https://issues.apache.org/jira/browse/KAFKA-5533 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-5531) Check exception handling in all streams tests

Eno Thereska created KAFKA-5531: --- Summary: Check exception handling in all streams tests Key: KAFKA-5531 URL: https://issues.apache.org/jira/browse/KAFKA-5531 Project: Kafka Issue Type: Sub-tas

[jira] [Reopened] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reopened KAFKA-5006: - > KeyValueStore.put may throw exception unrelated to the current put attempt > ---

[jira] [Created] (KAFKA-5524) Streams systems tests should be with EoS

Eno Thereska created KAFKA-5524: --- Summary: Streams systems tests should be with EoS Key: KAFKA-5524 URL: https://issues.apache.org/jira/browse/KAFKA-5524 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-4563. - Resolution: Duplicate This will be fixed as part of KAFKA-5372 > State transitions error PARTITIO

[jira] [Created] (KAFKA-5509) add gradle option for building tarball with test jars

Eno Thereska created KAFKA-5509: --- Summary: add gradle option for building tarball with test jars Key: KAFKA-5509 URL: https://issues.apache.org/jira/browse/KAFKA-5509 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5499) Double check how we handle exceptions when commits fail

Eno Thereska created KAFKA-5499: --- Summary: Double check how we handle exceptions when commits fail Key: KAFKA-5499 URL: https://issues.apache.org/jira/browse/KAFKA-5499 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-5487) Rolling upgrade test for streams

Eno Thereska created KAFKA-5487: --- Summary: Rolling upgrade test for streams Key: KAFKA-5487 URL: https://issues.apache.org/jira/browse/KAFKA-5487 Project: Kafka Issue Type: Bug Compon

[jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3514: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Stream timestamp computation needs

[jira] [Updated] (KAFKA-4641) Improve test coverage of StreamsThread

[ https://issues.apache.org/jira/browse/KAFKA-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4641: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of StreamsThr

[jira] [Updated] (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 ] Eno Thereska updated KAFKA-3779: Fix Version/s: (was: 0.11.0.0) > Add the LRU cache for KTable.to() operator > --

[jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage

[ https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4640: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve Streams unit test coverage

[jira] [Updated] (KAFKA-4653) Improve test coverage of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4653: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of RocksDBSto

[jira] [Updated] (KAFKA-4643) Improve test coverage of StreamsKafkaClient

[ https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4643: Fix Version/s: (was: 0.11.0.0) > Improve test coverage of StreamsKafkaClient > -

[jira] [Updated] (KAFKA-4651) Improve test coverage of Stores

[ https://issues.apache.org/jira/browse/KAFKA-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4651: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of Stores > -

[jira] [Updated] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4650: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage org.apache.ka

[jira] [Updated] (KAFKA-4655) Improve test coverage of CompositeReadOnlySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-4655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4655: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of CompositeR

[jira] [Updated] (KAFKA-4658) Improve test coverage InMemoryKeyValueLoggedStore

[ https://issues.apache.org/jira/browse/KAFKA-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4658: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage InMemoryKeyVa

[jira] [Updated] (KAFKA-4659) Improve test coverage of CachingKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4659: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of CachingKey

[jira] [Updated] (KAFKA-4656) Improve test coverage of CompositeReadOnlyKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4656: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve test coverage of CompositeR

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

[ https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4730: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Streams does not have an in-memory

[jira] [Updated] (KAFKA-4661) Improve test coverage UsePreviousTimeOnInvalidTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4661: Fix Version/s: (was: 0.11.0.0) > Improve test coverage UsePreviousTimeOnInvalidTimestamp > -

[jira] [Updated] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4696: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Streams standby task assignment sho

[jira] [Updated] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4729: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Stores for kstream-kstream join can

[jira] [Updated] (KAFKA-4875) Kafka Streams: topic groups and builder.stream API

[ https://issues.apache.org/jira/browse/KAFKA-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4875: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Kafka Streams: topic groups and bui

[jira] [Resolved] (KAFKA-4838) Export buffer cache metrics in JMX

[ https://issues.apache.org/jira/browse/KAFKA-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-4838. - Resolution: Won't Fix > Export buffer cache metrics in JMX > -- >

[jira] [Updated] (KAFKA-4904) Performance of RocksDb with state record cache

[ https://issues.apache.org/jira/browse/KAFKA-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4904: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Performance of RocksDb with state r

[jira] [Updated] (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 ] Eno Thereska updated KAFKA-4934: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Add streams test with RocksDb failu

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16026413#comment-16026413 ] Eno Thereska commented on KAFKA-5037: - [~mjsax] is this still for 0.11? > Infinite lo

[jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16026411#comment-16026411 ] Eno Thereska commented on KAFKA-5054: - [~damianguy] is this still for 0.11? > ChangeL

[jira] [Updated] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5301: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve exception handling on consu

[jira] [Updated] (KAFKA-5313) Improve exception handling on coordinator interactions

[ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5313: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve exception handling on coord

[jira] [Updated] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5302: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve exception handling on strea

[jira] [Updated] (KAFKA-5314) Improve exception handling for state stores

[ https://issues.apache.org/jira/browse/KAFKA-5314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5314: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve exception handling for stat

[jira] [Updated] (KAFKA-5300) Improve exception handling on producer path

[ https://issues.apache.org/jira/browse/KAFKA-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5300: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve exception handling on produ

[jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing

[ https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5158: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Options for handling exceptions dur

[jira] [Updated] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4563: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > State transitions error PARTITIONS_

[jira] [Updated] (KAFKA-5157) Options for handling corrupt data during deserialization

[ https://issues.apache.org/jira/browse/KAFKA-5157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5157: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Options for handling corrupt data d

[jira] [Updated] (KAFKA-5217) Improve Streams internal exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5217: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Improve Streams internal exception

[jira] [Commented] (KAFKA-5211) KafkaConsumer should not skip a corrupted record after throwing an exception.

[ https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024372#comment-16024372 ] Eno Thereska commented on KAFKA-5211: - Thanks [~becket_qin], [~ijuma], [~hachikuji]. M

[jira] [Updated] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5156: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Options for handling exceptions in

[jira] [Commented] (KAFKA-5315) Streams exception w/ partially processed record corrupts state store

[ https://issues.apache.org/jira/browse/KAFKA-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16023155#comment-16023155 ] Eno Thereska commented on KAFKA-5315: - [~mjsax] isn't this a fundamental problem that

[jira] [Updated] (KAFKA-4857) Use AdminClient in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4857: Summary: Use AdminClient in Kafka Streams (was: Improve Client handling) > Use AdminClient in Kafka

[jira] [Commented] (KAFKA-5211) KafkaConsumer should not skip a corrupted record after throwing an exception.

[ https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022824#comment-16022824 ] Eno Thereska commented on KAFKA-5211: - [~becket_qin] I think this change needs a KIP.

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022828#comment-16022828 ] Eno Thereska commented on KAFKA-4740: - I mentioned in KAFKA-5211 that such a change sh

[jira] [Updated] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5006: Resolution: Fixed Status: Resolved (was: Patch Available) > KeyValueStore.put may throw exc

[jira] [Work started] (KAFKA-5314) Improve exception handling for state stores

[ https://issues.apache.org/jira/browse/KAFKA-5314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5314 started by Eno Thereska. --- > Improve exception handling for state stores > ---

[jira] [Assigned] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5156: --- Assignee: Eno Thereska > Options for handling exceptions in streams > ---

[jira] [Resolved] (KAFKA-5312) Improve exception handling for StreamsKafkaClient

[ https://issues.apache.org/jira/browse/KAFKA-5312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-5312. - Resolution: Duplicate > Improve exception handling for StreamsKafkaClient > --

[jira] [Created] (KAFKA-5314) Improve exception handling for state stores

Eno Thereska created KAFKA-5314: --- Summary: Improve exception handling for state stores Key: KAFKA-5314 URL: https://issues.apache.org/jira/browse/KAFKA-5314 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5313) Improve exception handling on coordinator interactions

Eno Thereska created KAFKA-5313: --- Summary: Improve exception handling on coordinator interactions Key: KAFKA-5313 URL: https://issues.apache.org/jira/browse/KAFKA-5313 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5312) Improve exception handling for StreamsKafkaClient

Eno Thereska created KAFKA-5312: --- Summary: Improve exception handling for StreamsKafkaClient Key: KAFKA-5312 URL: https://issues.apache.org/jira/browse/KAFKA-5312 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

Eno Thereska created KAFKA-5302: --- Summary: Improve exception handling on streams client (communication with brokers) Key: KAFKA-5302 URL: https://issues.apache.org/jira/browse/KAFKA-5302 Project: Kafka

[jira] [Assigned] (KAFKA-5157) Options for handling corrupt data during deserialization

[ https://issues.apache.org/jira/browse/KAFKA-5157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5157: --- Assignee: Eno Thereska > Options for handling corrupt data during deserialization > -

[jira] [Created] (KAFKA-5301) Improve exception handling on consumer path

Eno Thereska created KAFKA-5301: --- Summary: Improve exception handling on consumer path Key: KAFKA-5301 URL: https://issues.apache.org/jira/browse/KAFKA-5301 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5300) Improve exception handling on producer path

Eno Thereska created KAFKA-5300: --- Summary: Improve exception handling on producer path Key: KAFKA-5300 URL: https://issues.apache.org/jira/browse/KAFKA-5300 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4868: Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Optimize RocksDb config for fast re

[jira] [Assigned] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4868: --- Assignee: Bill Bejeck (was: Eno Thereska) > Optimize RocksDb config for fast recovery/bulk l

[jira] [Updated] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4868: Priority: Major (was: Minor) > Optimize RocksDb config for fast recovery/bulk load > --

[jira] [Assigned] (KAFKA-4868) Optimize RocksDb config for fast recovery/bulk load

[ https://issues.apache.org/jira/browse/KAFKA-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4868: --- Assignee: Eno Thereska > Optimize RocksDb config for fast recovery/bulk load > --

[jira] [Created] (KAFKA-5254) rethink KTable API overloads

Eno Thereska created KAFKA-5254: --- Summary: rethink KTable API overloads Key: KAFKA-5254 URL: https://issues.apache.org/jira/browse/KAFKA-5254 Project: Kafka Issue Type: Improvement Co

[jira] [Commented] (KAFKA-5217) Improve Streams internal exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007013#comment-16007013 ] Eno Thereska commented on KAFKA-5217: - Do you want this as a subtask of https://issue

[jira] [Assigned] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5156: --- Assignee: (was: Eno Thereska) > Options for handling exceptions in streams >

[jira] [Updated] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5006: Priority: Blocker (was: Major) > KeyValueStore.put may throw exception unrelated to the current put

[jira] [Work started] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5156 started by Eno Thereska. --- > Options for handling exceptions in streams >

[jira] [Updated] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5006: Status: Patch Available (was: In Progress) > KeyValueStore.put may throw exception unrelated to the

[jira] [Work started] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5006 started by Eno Thereska. --- > KeyValueStore.put may throw exception unrelated to the current put attempt >

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16004711#comment-16004711 ] Eno Thereska commented on KAFKA-4689: - This is such a critical test, I understand why

[jira] [Commented] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002510#comment-16002510 ] Eno Thereska commented on KAFKA-3502: - This issue happens more in environments with re

[jira] [Commented] (KAFKA-5040) Increase number of Streams producer retries from the default of 0

[ https://issues.apache.org/jira/browse/KAFKA-5040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999314#comment-15999314 ] Eno Thereska commented on KAFKA-5040: - [~davispw] Yes, setting that variable to 1 atte

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998573#comment-15998573 ] Eno Thereska commented on KAFKA-4222: - Reopened. Continues to fail. I can repro on Lin

[jira] [Updated] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4222: Fix Version/s: (was: 0.10.1.0) 0.11.0.0 > Transient failure in QueryableState

[jira] [Assigned] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4222: --- Assignee: Eno Thereska > Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[jira] [Assigned] (KAFKA-5174) RocksDb might stall in environments with 1 core only

[ https://issues.apache.org/jira/browse/KAFKA-5174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5174: --- Assignee: Eno Thereska > RocksDb might stall in environments with 1 core only > -

[jira] [Created] (KAFKA-5174) RocksDb might stall in environments with 1 core only

Eno Thereska created KAFKA-5174: --- Summary: RocksDb might stall in environments with 1 core only Key: KAFKA-5174 URL: https://issues.apache.org/jira/browse/KAFKA-5174 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5144) MinTimestampTracker uses confusing variable names

[ https://issues.apache.org/jira/browse/KAFKA-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995746#comment-15995746 ] Eno Thereska commented on KAFKA-5144: - [~mihbor] thanks. I have a PR that cleans up th

[jira] [Created] (KAFKA-5158) Options for handling exceptions during processing

Eno Thereska created KAFKA-5158: --- Summary: Options for handling exceptions during processing Key: KAFKA-5158 URL: https://issues.apache.org/jira/browse/KAFKA-5158 Project: Kafka Issue Type: Sub

[jira] [Updated] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-5006: Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > KeyValueStore.put may throw exception

[jira] [Created] (KAFKA-5157) Options for handling corrupt data during deserialization

Eno Thereska created KAFKA-5157: --- Summary: Options for handling corrupt data during deserialization Key: KAFKA-5157 URL: https://issues.apache.org/jira/browse/KAFKA-5157 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-5156) Options for handling exceptions in streams

Eno Thereska created KAFKA-5156: --- Summary: Options for handling exceptions in streams Key: KAFKA-5156 URL: https://issues.apache.org/jira/browse/KAFKA-5156 Project: Kafka Issue Type: Task

[jira] [Assigned] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5006: --- Assignee: Eno Thereska > KeyValueStore.put may throw exception unrelated to the current put a

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4755: Resolution: Fixed Status: Resolved (was: Patch Available) > SimpleBenchmark test fails for

[jira] [Commented] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985499#comment-15985499 ] Eno Thereska commented on KAFKA-5005: - [~original-brownbear] absolutely, thank you! >

[jira] [Commented] (KAFKA-5124) shouldInnerLeftJoin unit test fails

[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982917#comment-15982917 ] Eno Thereska commented on KAFKA-5124: - Thanks [~original-brownbear] > shouldInnerLeft

[jira] [Created] (KAFKA-5124) shouldInnerLeftJoin unit test fails

Eno Thereska created KAFKA-5124: --- Summary: shouldInnerLeftJoin unit test fails Key: KAFKA-5124 URL: https://issues.apache.org/jira/browse/KAFKA-5124 Project: Kafka Issue Type: Bug Com

[jira] [Work started] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5097 started by Eno Thereska. --- > KafkaConsumer.poll throws IllegalStateException > ---

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4755: Fix Version/s: 0.10.2.1 > SimpleBenchmark test fails for streams > -

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4755: Summary: SimpleBenchmark test fails for streams (was: SimpleBenchmark consume test fails for stream

  1   2   3   4   5   >