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
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
Project
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
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
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
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
[
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
[https://github.com
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
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
Project
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:
[
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 rebala
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
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
[
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
[
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
[https://github.com
[
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 d
[
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.1
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
[
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 brok
[
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
[https://github.com
Damian Guy created KAFKA-5769:
-
Summary: Transient test failure
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache
Key: KAFKA-5769
URL: https
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
Project
[
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
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
[
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
[
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 repartition
[
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 repartition
[
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 fail
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
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
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
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: Sub
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: Sub
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: Sub
[
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
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
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
[
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
[
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
[https://github.com
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
[
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
[https://github.com
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: https://issues.apache.org/jira/b
[
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
[
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
[https://github.com
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
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
Components
[
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
[https://github.com
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
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3561:
-
Assignee: Damian Guy
> Auto create through topic for KStream aggregation and j
[
https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15303877#comment-15303877
]
Damian Guy commented on KAFKA-3561:
---
Guozhang - i'd like to do this if it i
Damian Guy created KAFKA-3835:
-
Summary: Streams is creating two ProducerRecords for each send via
RecordCollector
Key: KAFKA-3835
URL: https://issues.apache.org/jira/browse/KAFKA-3835
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3835:
--
Description:
The RecordCollector.send(..) method below, currently receives a ProducerRecord
from its
[
https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3835:
--
Description:
The RecordCollector.send(..) method below, currently receives a ProducerRecord
from its
[
https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3835:
--
Description:
The RecordCollector.send(..) method below, currently receives a ProducerRecord
from its
[
https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3576.
---
Resolution: Resolved
Resolved by https://issues.apache.org/jira/browse/KAFKA-3561
> Unify KStr
[
https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339455#comment-15339455
]
Damian Guy commented on KAFKA-3873:
---
This should be fixed - it was due to setting {
[
https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3873:
--
Comment: was deleted
(was: This should be fixed - it was due to setting {code
[
https://issues.apache.org/jira/browse/KAFKA-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15341627#comment-15341627
]
Damian Guy commented on KAFKA-3874:
---
This should be fixed with the commit yeste
[
https://issues.apache.org/jira/browse/KAFKA-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3874.
---
Resolution: Fixed
Fix Version/s: 0.10.1.0
Should be fixed by:
https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3896:
--
Assignee: Damian Guy
> Unstable t
Damian Guy created KAFKA-3898:
-
Summary: KStream.leftJoin(...) is missing a Serde for thisVal.
This can cause failures after mapValues etc
Key: KAFKA-3898
URL: https://issues.apache.org/jira/browse/KAFKA-3898
[
https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347901#comment-15347901
]
Damian Guy commented on KAFKA-3898:
---
If the stream has been mapped or flatMappe
[
https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347928#comment-15347928
]
Damian Guy commented on KAFKA-3898:
---
Turns out this is not an issue on 0.10.0
[
https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3898.
---
Resolution: Not A Problem
> KStream.leftJoin(...) is missing a Serde for thisVal. This can ca
Damian Guy created KAFKA-3912:
-
Summary: Query local state stores
Key: KAFKA-3912
URL: https://issues.apache.org/jira/browse/KAFKA-3912
Project: Kafka
Issue Type: Sub-task
Components
[
https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3912:
--
Description:
Implement read-only interface and QueryableStoreType for key-value state store
Implement
[
https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3912 started by Damian Guy.
-
> Query local state stores
>
>
>
Damian Guy created KAFKA-3914:
-
Summary: Global discovery of state stores
Key: KAFKA-3914
URL: https://issues.apache.org/jira/browse/KAFKA-3914
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-3914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3914 started by Damian Guy.
-
> Global discovery of state sto
[
https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3873:
-
Assignee: Damian Guy (was: Guozhang Wang)
> Gradle Test Executor non-zero exit code w
[
https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3873.
---
Resolution: Duplicate
Fix Version/s: 0.10.1.0
Fixed by KAFKA-3896
> Gradle Test Executor
[
https://issues.apache.org/jira/browse/KAFKA-3884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3884.
---
Resolution: Fixed
Fixed by KAFKA-3842
> KGroupedStreamIntegrationTest.shouldAggregate seems to
Damian Guy created KAFKA-3942:
-
Summary: Change IntegrationTestUtils.purgeLocalStreamsState to use
java.io.tmpdir
Key: KAFKA-3942
URL: https://issues.apache.org/jira/browse/KAFKA-3942
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3812:
-
Assignee: Damian Guy (was: Eno Thereska)
> State store locking is incorr
[
https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3855:
-
Assignee: Damian Guy
> Guard race conditions in TopologyBuil
[
https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3855 started by Damian Guy.
-
> Guard race conditions in TopologyBuil
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3740:
-
Assignee: Damian Guy (was: Henry Cai)
> Add configs for RocksDBSto
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3740:
--
Summary: Enable configuration of RocksDBStores (was: Add configs for
RocksDBStores)
> Ena
[
https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3929:
-
Assignee: Damian Guy (was: Ishita Mandhan)
> Add prefix for underlying clients configs
[
https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3929 started by Damian Guy.
-
> Add prefix for underlying clients configs in StreamCon
[
https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3929:
--
Status: Patch Available (was: In Progress)
> Add prefix for underlying clients configs in StreamCon
Damian Guy created KAFKA-4015:
-
Summary: Add new cleanup.policy, compact_and_delete
Key: KAFKA-4015
URL: https://issues.apache.org/jira/browse/KAFKA-4015
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3936:
--
Status: Patch Available (was: Open)
> Validate user parameters as early as possi
Damian Guy created KAFKA-4379:
-
Summary: Remove caching of dirty and removed keys from
StoreChangeLogger
Key: KAFKA-4379
URL: https://issues.apache.org/jira/browse/KAFKA-4379
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4379 started by Damian Guy.
-
> Remove caching of dirty and removed keys from StoreChangeLog
[
https://issues.apache.org/jira/browse/KAFKA-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4379:
--
Status: Patch Available (was: In Progress)
> Remove caching of dirty and removed keys f
[
https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4366:
--
Status: Patch Available (was: In Progress)
> KafkaStreams.close() blocks indefinit
[
https://issues.apache.org/jira/browse/KAFKA-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651233#comment-15651233
]
Damian Guy commented on KAFKA-4394:
---
The record timestamp is available
[
https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4270:
-
Assignee: Damian Guy
> ClassCast for Agregat
[
https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677990#comment-15677990
]
Damian Guy commented on KAFKA-4270:
---
Hi Mykola,
I'm not entirely sure i fo
[
https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677990#comment-15677990
]
Damian Guy edited comment on KAFKA-4270 at 11/18/16 10:4
[
https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684523#comment-15684523
]
Damian Guy commented on KAFKA-4270:
---
Hi,
I still don't really follow what the
[
https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3452 started by Damian Guy.
-
> Support session windows besides time interval wind
[
https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3452:
--
Description:
The Streams DSL currently does not provide session window as in the DataFlow
model. We
[
https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3452:
--
Summary: Support session windows (was: Support session windows besides
time interval windows
[
https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3452:
--
Status: Patch Available (was: In Progress)
> Support session wind
[
https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715322#comment-15715322
]
Damian Guy commented on KAFKA-4322:
---
My only concern with adding the extra method
Damian Guy created KAFKA-4488:
-
Summary: UnsupportedOperationException during initialization of
StandbyTask
Key: KAFKA-4488
URL: https://issues.apache.org/jira/browse/KAFKA-4488
Project: Kafka
401 - 500 of 765 matches
Mail list logo
