[
https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated KAFKA-4392:
--
Comment: was deleted
(was: I am still seeing this error in 0.10.2.0 during rebalances. Reopen or
creat
[
https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937388#comment-15937388
]
Elias Levy commented on KAFKA-4392:
---
I am still seeing this error in 0.10.2.0 during reb
[
https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937389#comment-15937389
]
Elias Levy commented on KAFKA-4392:
---
I am still seeing this error in 0.10.2.0 during reb
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated KAFKA-4919:
--
Summary: Document that stores must not be closed when Processors are closed
(was: Streams job fails wit
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936714#comment-15936714
]
Elias Levy commented on KAFKA-4919:
---
Thanks for the information. It is something that s
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935711#comment-15935711
]
Elias Levy commented on KAFKA-4919:
---
I believe I found the issue. I am closing the stor
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935252#comment-15935252
]
Elias Levy commented on KAFKA-4919:
---
The issue appears to be that a {{RocksDBStore}} seg
[
https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated KAFKA-4919:
--
Summary: Streams job fails with InvalidStateStoreException: Store is
currently closed (was: Streams job
Elias Levy created KAFKA-4919:
-
Summary: Streams job fails with StreamsExceptio
Key: KAFKA-4919
URL: https://issues.apache.org/jira/browse/KAFKA-4919
Project: Kafka
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922826#comment-15922826
]
Elias Levy commented on KAFKA-4887:
---
It is a bit complicated. I am abusing the {{RocksD
Elias Levy created KAFKA-4887:
-
Summary: Enabling caching on a persistent window store breaks
support for duplicate insertion
Key: KAFKA-4887
URL: https://issues.apache.org/jira/browse/KAFKA-4887
Project:
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868971#comment-15868971
]
Elias Levy commented on KAFKA-2729:
---
Hit this again during testing with 0.10.0.1 on a 10
Elias Levy created KAFKA-4748:
-
Summary: Need a way to shutdown all workers in a Streams
application at the same time
Key: KAFKA-4748
URL: https://issues.apache.org/jira/browse/KAFKA-4748
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15836739#comment-15836739
]
Elias Levy commented on KAFKA-4144:
---
What Matthias said. The issue has nothing to do wi
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15833913#comment-15833913
]
Elias Levy commented on KAFKA-4144:
---
Jeyhun, sorry if I was not clear. My comment about
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15833649#comment-15833649
]
Elias Levy commented on KAFKA-4144:
---
That's fine. I am less concerned about the impleme
Elias Levy created KAFKA-4683:
-
Summary: Mismatch between Stream windowed store and broker log
retention logic
Key: KAFKA-4683
URL: https://issues.apache.org/jira/browse/KAFKA-4683
Project: Kafka
Elias Levy created KAFKA-4639:
-
Summary: Kafka Streams metrics are undocumented
Key: KAFKA-4639
URL: https://issues.apache.org/jira/browse/KAFKA-4639
Project: Kafka
Issue Type: Bug
Comp
Elias Levy created KAFKA-4608:
-
Summary: RocksDBWindowStore.fetch() is inefficient for large ranges
Key: KAFKA-4608
URL: https://issues.apache.org/jira/browse/KAFKA-4608
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15556371#comment-15556371
]
Elias Levy commented on KAFKA-4217:
---
That would work as well.
> KStream.transform equiv
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1654#comment-1654
]
Elias Levy commented on KAFKA-4217:
---
It would seem to be the same request: allow a trans
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531353#comment-15531353
]
Elias Levy commented on KAFKA-4212:
---
I am using the {{KStream.transform}} API, the {{Tra
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531116#comment-15531116
]
Elias Levy commented on KAFKA-4212:
---
But joins are not performed on hopping windows, the
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531022#comment-15531022
]
Elias Levy commented on KAFKA-4212:
---
Not sure I follow.
> Add a key-value store that
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15530995#comment-15530995
]
Elias Levy commented on KAFKA-4212:
---
I would described it as a TTL, not LRU. We want th
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527841#comment-15527841
]
Elias Levy commented on KAFKA-4212:
---
Looks like using {{WindowStore}} is not quite so si
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527301#comment-15527301
]
Elias Levy commented on KAFKA-4144:
---
Indeed, that is how it is handled today. But it's
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524513#comment-15524513
]
Elias Levy commented on KAFKA-4212:
---
More generally, the use case is: I've told a bunch
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15524402#comment-15524402
]
Elias Levy commented on KAFKA-4212:
---
The general use case is the joining of updates to t
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15521287#comment-15521287
]
Elias Levy edited comment on KAFKA-4212 at 9/25/16 7:17 PM:
It
[
https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15521287#comment-15521287
]
Elias Levy commented on KAFKA-4212:
---
I should be noted that a variable-capacity memory-o
Elias Levy created KAFKA-4219:
-
Summary: Permit setting of event time in stream processor
Key: KAFKA-4219
URL: https://issues.apache.org/jira/browse/KAFKA-4219
Project: Kafka
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/KAFKA-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15521271#comment-15521271
]
Elias Levy commented on KAFKA-4120:
---
{{o.a.k.common.utils.Bytes}} is not a documented cl
Elias Levy created KAFKA-4218:
-
Summary: Enable access to key in {{ValueTransformer}}
Key: KAFKA-4218
URL: https://issues.apache.org/jira/browse/KAFKA-4218
Project: Kafka
Issue Type: Improvement
Elias Levy created KAFKA-4217:
-
Summary: KStream.transform equivalent of flatMap
Key: KAFKA-4217
URL: https://issues.apache.org/jira/browse/KAFKA-4217
Project: Kafka
Issue Type: Improvement
Elias Levy created KAFKA-4212:
-
Summary: Add a key-value store that is a TTL persistent cache
Key: KAFKA-4212
URL: https://issues.apache.org/jira/browse/KAFKA-4212
Project: Kafka
Issue Type: Impr
[
https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491553#comment-15491553
]
Elias Levy commented on KAFKA-4153:
---
I've updated the PR to reverse the before & after s
[
https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485826#comment-15485826
]
Elias Levy commented on KAFKA-4153:
---
Why would the other value be undefined? Default it
[
https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485700#comment-15485700
]
Elias Levy commented on KAFKA-4153:
---
You could do that, but it would be non-obvious to s
[
https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485561#comment-15485561
]
Elias Levy commented on KAFKA-4153:
---
As a side note, the API for {{JoinWindows}} has bec
[
https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated KAFKA-4153:
--
Flags: Patch
> Incorrect KStream-KStream join behavior with asymmetric time window
> ---
Elias Levy created KAFKA-4153:
-
Summary: Incorrect KStream-KStream join behavior with asymmetric
time window
Key: KAFKA-4153
URL: https://issues.apache.org/jira/browse/KAFKA-4153
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy resolved KAFKA-4146.
---
Resolution: Invalid
> Kafka Stream ignores Serde exceptions leading to silently broken apps
>
Elias Levy created KAFKA-4146:
-
Summary: Kafka Stream ignores Serde exceptions leading to silently
broken apps
Key: KAFKA-4146
URL: https://issues.apache.org/jira/browse/KAFKA-4146
Project: Kafka
Elias Levy created KAFKA-4144:
-
Summary: Allow per stream/table timestamp extractor
Key: KAFKA-4144
URL: https://issues.apache.org/jira/browse/KAFKA-4144
Project: Kafka
Issue Type: Improvement
Elias Levy created KAFKA-3932:
-
Summary: Consumer fails to consume in a round robin fashion
Key: KAFKA-3932
URL: https://issues.apache.org/jira/browse/KAFKA-3932
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346678#comment-15346678
]
Elias Levy commented on KAFKA-2359:
---
I wonder if the calling pause() before calling poll
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133716#comment-15133716
]
Elias Levy commented on KAFKA-2729:
---
Had the same issue happen here while testing a 5 no
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15133716#comment-15133716
]
Elias Levy edited comment on KAFKA-2729 at 2/5/16 5:55 AM:
---
Had
49 matches
Mail list logo
