[jira] [Resolved] (KAFKA-6577) Connect standalone SASL file source and sink test fails without explanation

[ https://issues.apache.org/jira/browse/KAFKA-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6577. --- Resolution: Fixed Fix Version/s: 1.2.0 Issue resolved by pull request 4610

[jira] [Resolved] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6378. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4424

[jira] [Resolved] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

[ https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6412. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4372

[jira] [Created] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

Damian Guy created KAFKA-6360: - Summary: RocksDB segments not removed when store is closed causes re-initialization to fail Key: KAFKA-6360 URL: https://issues.apache.org/jira/browse/KAFKA-6360 Project:

[jira] [Created] (KAFKA-6349) ConcurrentModificationException during streams state restoration

Damian Guy created KAFKA-6349: - Summary: ConcurrentModificationException during streams state restoration Key: KAFKA-6349 URL: https://issues.apache.org/jira/browse/KAFKA-6349 Project: Kafka

[jira] [Created] (KAFKA-6259) Make KafkaStreams.cleanup() clean global state directory

Damian Guy created KAFKA-6259: - Summary: Make KafkaStreams.cleanup() clean global state directory Key: KAFKA-6259 URL: https://issues.apache.org/jira/browse/KAFKA-6259 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6186) RocksDB based WindowStore fail to create db file on Windows OS

[ https://issues.apache.org/jira/browse/KAFKA-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6186. --- Resolution: Duplicate > RocksDB based WindowStore fail to create db file on Windows OS >

[jira] [Resolved] (KAFKA-6069) Streams metrics tagged incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6069. --- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-6023) ThreadCache#sizeBytes() should check overflow

[ https://issues.apache.org/jira/browse/KAFKA-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6023. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4041

[jira] [Resolved] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4890. --- Resolution: Duplicate > State directory being deleted when another thread holds the lock >

[jira] [Resolved] (KAFKA-5985) Mention the need to close store iterators

[ https://issues.apache.org/jira/browse/KAFKA-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5985. --- Resolution: Fixed Issue resolved by pull request 3994 [https://github.com/apache/kafka/pull/3994] >

[jira] [Created] (KAFKA-6001) Remove <Bytes, byte[]> from usages of Materialized in Streams

Damian Guy created KAFKA-6001: - Summary: Remove from usages of Materialized in Streams Key: KAFKA-6001 URL: https://issues.apache.org/jira/browse/KAFKA-6001 Project: Kafka Issue

[jira] [Created] (KAFKA-5986) Streams State Restoration never completes when logging is disabled

Damian Guy created KAFKA-5986: - Summary: Streams State Restoration never completes when logging is disabled Key: KAFKA-5986 URL: https://issues.apache.org/jira/browse/KAFKA-5986 Project: Kafka

[jira] [Resolved] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5765. --- Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.0.0 Issue resolved by

[jira] [Resolved] (KAFKA-5489) Failing test: InternalTopicIntegrationTest.shouldCompactTopicsForStateChangelogs

[ https://issues.apache.org/jira/browse/KAFKA-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5489. --- Resolution: Cannot Reproduce Closing this as i haven't seen it fail in a while and i'm unable to

[jira] [Resolved] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized

[ https://issues.apache.org/jira/browse/KAFKA-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5956. --- Resolution: Fixed Issue resolved by pull request 3936 [https://github.com/apache/kafka/pull/3936] >

[jira] [Created] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized

Damian Guy created KAFKA-5956: - Summary: StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized Key: KAFKA-5956 URL: https://issues.apache.org/jira/browse/KAFKA-5956

[jira] [Resolved] (KAFKA-5931) Deprecate KTable#to and KTable#through

[ https://issues.apache.org/jira/browse/KAFKA-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5931. --- Resolution: Fixed Issue resolved by pull request 3903 [https://github.com/apache/kafka/pull/3903] >

[jira] [Created] (KAFKA-5939) Add a dryrun option to release.py

Damian Guy created KAFKA-5939: - Summary: Add a dryrun option to release.py Key: KAFKA-5939 URL: https://issues.apache.org/jira/browse/KAFKA-5939 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5931) Deprecate KTable#to and KTable#through

Damian Guy created KAFKA-5931: - Summary: Deprecate KTable#to and KTable#through Key: KAFKA-5931 URL: https://issues.apache.org/jira/browse/KAFKA-5931 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-5873) Add Materialized overloads to StreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5873. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3837

[jira] [Created] (KAFKA-5922) Add SessionWindowedKStream

Damian Guy created KAFKA-5922: - Summary: Add SessionWindowedKStream Key: KAFKA-5922 URL: https://issues.apache.org/jira/browse/KAFKA-5922 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5921) Add Materialized overloads to WindowedKStream

Damian Guy created KAFKA-5921: - Summary: Add Materialized overloads to WindowedKStream Key: KAFKA-5921 URL: https://issues.apache.org/jira/browse/KAFKA-5921 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-5754) Refactor Streams to use LogContext

[ https://issues.apache.org/jira/browse/KAFKA-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5754. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3727

[jira] [Resolved] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times

[ https://issues.apache.org/jira/browse/KAFKA-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5908. --- Resolution: Fixed Issue resolved by pull request 3868 [https://github.com/apache/kafka/pull/3868] >

[jira] [Created] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times

Damian Guy created KAFKA-5908: - Summary: CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times Key: KAFKA-5908 URL:

[jira] [Resolved] (KAFKA-5655) Add new API methods to KGroupedTable

[ https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5655. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3829

[jira] [Created] (KAFKA-5873) Add Materialized overloads to StreamBuilder

Damian Guy created KAFKA-5873: - Summary: Add Materialized overloads to StreamBuilder Key: KAFKA-5873 URL: https://issues.apache.org/jira/browse/KAFKA-5873 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-5853) Add WindowedKStream interface and implemenation

[ https://issues.apache.org/jira/browse/KAFKA-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5853. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3809

[jira] [Resolved] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5832. --- Resolution: Fixed Issue resolved by pull request 3784 [https://github.com/apache/kafka/pull/3784] >

[jira] [Created] (KAFKA-5853) Add WindowedKStream interface and implemenation

Damian Guy created KAFKA-5853: - Summary: Add WindowedKStream interface and implemenation Key: KAFKA-5853 URL: https://issues.apache.org/jira/browse/KAFKA-5853 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable

Damian Guy created KAFKA-5852: - Summary: Add filter, filterNot, mapValues and Materialized to KTable Key: KAFKA-5852 URL: https://issues.apache.org/jira/browse/KAFKA-5852 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable

[ https://issues.apache.org/jira/browse/KAFKA-5844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5844. --- Resolution: Fixed Issue resolved by pull request 3802 [https://github.com/apache/kafka/pull/3802] >

[jira] [Created] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable

Damian Guy created KAFKA-5844: - Summary: Add groupBy(KeyValueMapper, Serialized) to KTable Key: KAFKA-5844 URL: https://issues.apache.org/jira/browse/KAFKA-5844 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder

Damian Guy created KAFKA-5832: - Summary: Add Consumed class and overloads to StreamBuilder Key: KAFKA-5832 URL: https://issues.apache.org/jira/browse/KAFKA-5832 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5819) Add Joined class and relevant KStream join overloads

Damian Guy created KAFKA-5819: - Summary: Add Joined class and relevant KStream join overloads Key: KAFKA-5819 URL: https://issues.apache.org/jira/browse/KAFKA-5819 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

Damian Guy created KAFKA-5817: - Summary: Add Serialized class and KStream groupBy and groupByKey overloads Key: KAFKA-5817 URL: https://issues.apache.org/jira/browse/KAFKA-5817 Project: Kafka

[jira] [Created] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

Damian Guy created KAFKA-5816: - Summary: Add Produced class and new to and through overloads to KStream Key: KAFKA-5816 URL: https://issues.apache.org/jira/browse/KAFKA-5816 Project: Kafka

[jira] [Created] (KAFKA-5815) Add Printed class and KStream#print(Printed)

Damian Guy created KAFKA-5815: - Summary: Add Printed class and KStream#print(Printed) Key: KAFKA-5815 URL: https://issues.apache.org/jira/browse/KAFKA-5815 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache

[ https://issues.apache.org/jira/browse/KAFKA-5769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5769. --- Resolution: Duplicate > Transient test failure >

[jira] [Resolved] (KAFKA-4835) Allow users control over repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4835. --- Resolution: Duplicate > Allow users control over repartitioning >

[jira] [Reopened] (KAFKA-4835) Allow users control over repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reopened KAFKA-4835: --- > Allow users control over repartitioning > --- > >

[jira] [Resolved] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log

[ https://issues.apache.org/jira/browse/KAFKA-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5804. --- Resolution: Fixed Issue resolved by pull request 3754 [https://github.com/apache/kafka/pull/3754] >

[jira] [Created] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log

Damian Guy created KAFKA-5804: - Summary: ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log Key: KAFKA-5804 URL: https://issues.apache.org/jira/browse/KAFKA-5804 Project:

[jira] [Resolved] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order

[ https://issues.apache.org/jira/browse/KAFKA-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5771. --- Resolution: Fixed Fix Version/s: 0.11.0.1 1.0.0 Issue resolved by pull

[jira] [Created] (KAFKA-5787) StoreChangeLogReader needs to restore partitions that were added post initialization

Damian Guy created KAFKA-5787: - Summary: StoreChangeLogReader needs to restore partitions that were added post initialization Key: KAFKA-5787 URL: https://issues.apache.org/jira/browse/KAFKA-5787

[jira] [Created] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache

Damian Guy created KAFKA-5769: - Summary: Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache Key: KAFKA-5769 URL:

[jira] [Resolved] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store

[ https://issues.apache.org/jira/browse/KAFKA-5689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5689. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3692

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

[ https://issues.apache.org/jira/browse/KAFKA-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5725. --- Resolution: Fixed > Additional failure testing for streams with bouncing brokers >

[jira] [Created] (KAFKA-5749) Refactor SessionStore hierarchy

Damian Guy created KAFKA-5749: - Summary: Refactor SessionStore hierarchy Key: KAFKA-5749 URL: https://issues.apache.org/jira/browse/KAFKA-5749 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5242. --- Resolution: Won't Do This has been fixed by KAFKA-5152 which has already been merged to 0.11.0.1

[jira] [Resolved] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5440. --- Resolution: Duplicate > Kafka Streams report state RUNNING even if all threads are dead >

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

[ https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4643. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3663

[jira] [Resolved] (KAFKA-5717) [streams] 'null' values in state stores

[ https://issues.apache.org/jira/browse/KAFKA-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5717. --- Resolution: Fixed Fix Version/s: 0.11.0.1 1.0.0 Issue resolved by pull

[jira] [Created] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

Damian Guy created KAFKA-5702: - Summary: Refactor StreamThread to separate concerns and enable better testability Key: KAFKA-5702 URL: https://issues.apache.org/jira/browse/KAFKA-5702 Project: Kafka

[jira] [Created] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store

Damian Guy created KAFKA-5689: - Summary: Refactor WindowStore hierarchy so that Metered Store is the outermost store Key: KAFKA-5689 URL: https://issues.apache.org/jira/browse/KAFKA-5689 Project: Kafka

[jira] [Resolved] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5154. --- Resolution: Fixed > Kafka Streams throws NPE during rebalance >

[jira] [Created] (KAFKA-5680) Don't materliaze physical state stores in KTable filter/map etc operations

Damian Guy created KAFKA-5680: - Summary: Don't materliaze physical state stores in KTable filter/map etc operations Key: KAFKA-5680 URL: https://issues.apache.org/jira/browse/KAFKA-5680 Project: Kafka

[jira] [Created] (KAFKA-5673) Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store

Damian Guy created KAFKA-5673: - Summary: Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store Key: KAFKA-5673 URL: https://issues.apache.org/jira/browse/KAFKA-5673

[jira] [Created] (KAFKA-5672) Move measureLatencyNs from StreamsMetricsImpl to StreamsMetrics

Damian Guy created KAFKA-5672: - Summary: Move measureLatencyNs from StreamsMetricsImpl to StreamsMetrics Key: KAFKA-5672 URL: https://issues.apache.org/jira/browse/KAFKA-5672 Project: Kafka

[jira] [Resolved] (KAFKA-5549) Explain that `client.id` is just used as a prefix within Streams

[ https://issues.apache.org/jira/browse/KAFKA-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5549. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3544

[jira] [Created] (KAFKA-5655) Add new API methods to KGroupedTable

Damian Guy created KAFKA-5655: - Summary: Add new API methods to KGroupedTable Key: KAFKA-5655 URL: https://issues.apache.org/jira/browse/KAFKA-5655 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5653) Add new API methods to KTable

Damian Guy created KAFKA-5653: - Summary: Add new API methods to KTable Key: KAFKA-5653 URL: https://issues.apache.org/jira/browse/KAFKA-5653 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5654) Add new API methods to KGroupedStream

Damian Guy created KAFKA-5654: - Summary: Add new API methods to KGroupedStream Key: KAFKA-5654 URL: https://issues.apache.org/jira/browse/KAFKA-5654 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5652) Add new api methods to KStream

Damian Guy created KAFKA-5652: - Summary: Add new api methods to KStream Key: KAFKA-5652 URL: https://issues.apache.org/jira/browse/KAFKA-5652 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

Damian Guy created KAFKA-5651: - Summary: KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines Key: KAFKA-5651 URL: https://issues.apache.org/jira/browse/KAFKA-5651

[jira] [Created] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

Damian Guy created KAFKA-5650: - Summary: Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182) Key: KAFKA-5650 URL: https://issues.apache.org/jira/browse/KAFKA-5650

[jira] [Resolved] (KAFKA-3741) Allow setting of default topic configs via StreamsConfig

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3741. --- Resolution: Fixed Fix Version/s: 0.11.1.0 Issue resolved by pull request 3459

[jira] [Resolved] (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 ] Damian Guy resolved KAFKA-5157. --- Resolution: Fixed Issue resolved by pull request 3423 [https://github.com/apache/kafka/pull/3423] >

[jira] [Created] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

Damian Guy created KAFKA-5578: - Summary: Streams Task Assignor should consider the staleness of state directories when allocating tasks Key: KAFKA-5578 URL: https://issues.apache.org/jira/browse/KAFKA-5578

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

[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5566. --- Resolution: Fixed Fix Version/s: 0.11.0.1 0.11.1.0 Issue resolved by pull

[jira] [Created] (KAFKA-5562) Do streams state directory cleanup on a single thread

Damian Guy created KAFKA-5562: - Summary: Do streams state directory cleanup on a single thread Key: KAFKA-5562 URL: https://issues.apache.org/jira/browse/KAFKA-5562 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5508) Documentation for altering topics

[ https://issues.apache.org/jira/browse/KAFKA-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5508. --- Resolution: Fixed Fix Version/s: 0.11.0.1 0.11.1.0 Issue resolved by pull

[jira] [Created] (KAFKA-5556) KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to retrieve exception from future which hasn't failed

Damian Guy created KAFKA-5556: - Summary: KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to retrieve exception from future which hasn't failed Key: KAFKA-5556 URL:

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

[ https://issues.apache.org/jira/browse/KAFKA-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5487. --- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 0.11.1.0 Issue

[jira] [Resolved] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4913. --- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 0.11.1.0 Issue

[jira] [Updated] (KAFKA-3741) KStream config for changelog min.in.sync.replicas

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3741: -- Status: Patch Available (was: Open) > KStream config for changelog min.in.sync.replicas >

[jira] [Assigned] (KAFKA-3741) KStream config for changelog min.in.sync.replicas

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3741: - Assignee: Damian Guy > KStream config for changelog min.in.sync.replicas >

[jira] [Updated] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4913: -- Status: In Progress (was: Patch Available) > creating a window store with one segment throws division

[jira] [Work stopped] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4913 stopped by Damian Guy. - > creating a window store with one segment throws division by zero error >

[jira] [Work started] (KAFKA-5357) StackOverFlow error in transaction coordinator

[ https://issues.apache.org/jira/browse/KAFKA-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5357 started by Damian Guy. - > StackOverFlow error in transaction coordinator >

[jira] [Assigned] (KAFKA-5357) StackOverFlow error in transaction coordinator

[ https://issues.apache.org/jira/browse/KAFKA-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5357: - Assignee: Damian Guy > StackOverFlow error in transaction coordinator >

[jira] [Resolved] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4953. --- Resolution: Fixed fixed by KAFKA-5045 > Global Store: cast exception when initialising with

[jira] [Resolved] (KAFKA-4270) ClassCast for Agregation

[ https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4270. --- Resolution: Cannot Reproduce Closing this as haven't been able to reproduce and no further

[jira] [Updated] (KAFKA-5308) TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response

[ https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5308: -- Status: Patch Available (was: Open) > TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in

[jira] [Commented] (KAFKA-5308) TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response

[ https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16021295#comment-16021295 ] Damian Guy commented on KAFKA-5308: --- [~hachikuji] i think this may not be possible once

[jira] [Assigned] (KAFKA-5308) TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response

[ https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5308: - Assignee: Damian Guy > TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker

[jira] [Updated] (KAFKA-5260) Producer should not send AbortTxn unless transaction has actually begun

[ https://issues.apache.org/jira/browse/KAFKA-5260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5260: -- Status: Patch Available (was: Open) > Producer should not send AbortTxn unless transaction has

[jira] [Updated] (KAFKA-5279) TransactionCoordinator must expire transactionalIds

[ https://issues.apache.org/jira/browse/KAFKA-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5279: -- Status: Patch Available (was: Open) > TransactionCoordinator must expire transactionalIds >

[jira] [Assigned] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5154: - Assignee: Damian Guy (was: Matthias J. Sax) > Kafka Streams throws NPE during rebalance >

[jira] [Created] (KAFKA-5288) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic

Damian Guy created KAFKA-5288: - Summary: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic Key: KAFKA-5288 URL:

[jira] [Reopened] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reopened KAFKA-5063: --- > Flaky > ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic >

[jira] [Commented] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017058#comment-16017058 ] Damian Guy commented on KAFKA-5063: --- Another instance of this failure: {noformat}

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015805#comment-16015805 ] Damian Guy commented on KAFKA-5256: --- >From 0.11.0 onwards we will always have a checkpoint unless

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015615#comment-16015615 ] Damian Guy commented on KAFKA-5154: --- [~Lukas Gemela] Thanks for attaching the full logs. [~mjsax]

[jira] [Updated] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5154: -- Attachment: 5154_problem.log > Kafka Streams throws NPE during rebalance >

[jira] [Commented] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

[ https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012270#comment-16012270 ] Damian Guy commented on KAFKA-5241: --- [~twbecker] Probably worth filing another JIRA for this as it is

[jira] [Created] (KAFKA-5219) Move transaction expiration logic and scheduling to the Transaction Manager

Damian Guy created KAFKA-5219: - Summary: Move transaction expiration logic and scheduling to the Transaction Manager Key: KAFKA-5219 URL: https://issues.apache.org/jira/browse/KAFKA-5219 Project: Kafka

[jira] [Assigned] (KAFKA-5129) TransactionCoordinator - Add ACL check for each request

[ https://issues.apache.org/jira/browse/KAFKA-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5129: - Assignee: Damian Guy > TransactionCoordinator - Add ACL check for each request >

[jira] [Updated] (KAFKA-5168) Cleanup delayed produce purgatory during partition emmigration

[ https://issues.apache.org/jira/browse/KAFKA-5168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5168: -- Resolution: Not A Problem Status: Resolved (was: Patch Available) This is already handled >

  1   2   3   4   >