[
https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106404#comment-16106404
]
Matthias J. Sax commented on KAFKA-5233:
I agree with [~mihbor] that we might want to keep the old
[
https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106405#comment-16106405
]
Matthias J. Sax commented on KAFKA-5677:
Not sure if we should do this. See my comment on
[
https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16078420#comment-16078420
]
Matthias J. Sax commented on KAFKA-5571:
[~enothereska] Did some rework on state management in
Matthias J. Sax created KAFKA-5603:
--
Summary: Streams should not abort transaction when closing zombie
task
Key: KAFKA-5603
URL: https://issues.apache.org/jira/browse/KAFKA-5603
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5167:
---
Fix Version/s: 0.10.2.2
> streams task gets stuck after re-balance due to LockException
>
[
https://issues.apache.org/jira/browse/KAFKA-5577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5577.
Resolution: Fixed
Fixed via https://github.com/apache/kafka/pull/2776
>
Matthias J. Sax created KAFKA-5577:
--
Summary: WindowedStreamPartitioner does not provide topic name to
serializer
Key: KAFKA-5577
URL: https://issues.apache.org/jira/browse/KAFKA-5577
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076901#comment-16076901
]
Matthias J. Sax commented on KAFKA-4490:
See: https://issues.apache.org/jira/browse/KAFKA-4628
>
Matthias J. Sax created KAFKA-5566:
--
Summary: Instable test
QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied
Key: KAFKA-5566
URL: https://issues.apache.org/jira/browse/KAFKA-5566
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4819:
---
Fix Version/s: 0.11.1.0
> Expose states of active tasks to public API
>
[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091762#comment-16091762
]
Matthias J. Sax commented on KAFKA-5386:
For internal repartitioning topics, you can always avoid
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094568#comment-16094568
]
Matthias J. Sax commented on KAFKA-4750:
As mentioned above. I would go with option (1) as null
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095776#comment-16095776
]
Matthias J. Sax commented on KAFKA-4750:
I understand what you are saying, but encoding an empty
[
https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095769#comment-16095769
]
Matthias J. Sax commented on KAFKA-4468:
[~guozhang] We have to distinguish two cases: (1)
[
https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095784#comment-16095784
]
Matthias J. Sax commented on KAFKA-5618:
Thanks for following up. If it hangs and the threads
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100120#comment-16100120
]
Matthias J. Sax commented on KAFKA-4327:
[~jeqo] I assigned this to you, as it is be covered by
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4327:
--
Assignee: Jorge Quilcate (was: Matthias J. Sax)
> Move Reset Tool from core to
[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098591#comment-16098591
]
Matthias J. Sax edited comment on KAFKA-5386 at 7/24/17 3:39 PM:
-
Well.
[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098591#comment-16098591
]
Matthias J. Sax commented on KAFKA-5386:
Well. With regard to ACL, you can still know the names of
[
https://issues.apache.org/jira/browse/KAFKA-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103319#comment-16103319
]
Matthias J. Sax commented on KAFKA-5648:
The issue is, if one implements old {{Merger}} and does a
Matthias J. Sax created KAFKA-5671:
--
Summary: Add StreamsBuilder and deprecate KStreamBuilder
Key: KAFKA-5671
URL: https://issues.apache.org/jira/browse/KAFKA-5671
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101659#comment-16101659
]
Matthias J. Sax commented on KAFKA-4327:
It's Streams tool, so it belongs to package
[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101652#comment-16101652
]
Matthias J. Sax commented on KAFKA-5386:
Understood. Technically, it would be possible to allow
[
https://issues.apache.org/jira/browse/KAFKA-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102119#comment-16102119
]
Matthias J. Sax commented on KAFKA-5648:
Your observation is correct, that {{Merger}} and
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097368#comment-16097368
]
Matthias J. Sax edited comment on KAFKA-4750 at 7/22/17 3:41 PM:
-
IMHO, we
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097368#comment-16097368
]
Matthias J. Sax commented on KAFKA-4750:
IMHO, we can also improve the code by not calling the
[
https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068951#comment-16068951
]
Matthias J. Sax commented on KAFKA-5530:
Also, Kafka {{0.11.0.0}} was released today. It would be
[
https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068935#comment-16068935
]
Matthias J. Sax commented on KAFKA-4468:
[~evis] In
Matthias J. Sax created KAFKA-5541:
--
Summary: Streams should not re-throw if suspending/closing task
fails
Key: KAFKA-5541
URL: https://issues.apache.org/jira/browse/KAFKA-5541
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16067362#comment-16067362
]
Matthias J. Sax commented on KAFKA-5167:
[~habdank] Seems you created
[
https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070474#comment-16070474
]
Matthias J. Sax edited comment on KAFKA-5545 at 6/30/17 5:54 PM:
-
Hi. The
[
https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072596#comment-16072596
]
Matthias J. Sax commented on KAFKA-5530:
Glad you could resolve your problem. We did change the
[
https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072587#comment-16072587
]
Matthias J. Sax commented on KAFKA-5545:
Can you do me a favor and attach the log file instead of
[
https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072622#comment-16072622
]
Matthias J. Sax commented on KAFKA-5528:
[~nravi] I guess the problem is, that you are using a
[
https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076830#comment-16076830
]
Matthias J. Sax commented on KAFKA-4468:
Thanks for following up. About storing the window size --
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075056#comment-16075056
]
Matthias J. Sax commented on KAFKA-5070:
I was working on
[
https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5528.
Resolution: Not A Bug
> Error while reading topic, offset, partition info from process
[
https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075191#comment-16075191
]
Matthias J. Sax commented on KAFKA-5528:
Added FAQ:
[
https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-5167:
This seems to got broken via
[
https://issues.apache.org/jira/browse/KAFKA-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065505#comment-16065505
]
Matthias J. Sax commented on KAFKA-4344:
What version are you using?
> Exception when accessing
[
https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5528:
---
Description:
We are encountering an {{IllegalStateException}} while trying to access
[
https://issues.apache.org/jira/browse/KAFKA-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065609#comment-16065609
]
Matthias J. Sax commented on KAFKA-4344:
You did create
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-3745.
Resolution: Duplicate
See
[
https://issues.apache.org/jira/browse/KAFKA-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4726:
--
Assignee: Jeyhun Karimov
> ValueMapper should have (read) access to key
>
[
https://issues.apache.org/jira/browse/KAFKA-5318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16077336#comment-16077336
]
Matthias J. Sax commented on KAFKA-5318:
Is this contained by KAFKA-5372 ? \cc [~enothereska]
>
[
https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4125:
---
Labels: kip (was: )
> Provide low-level Processor API meta data in DSL layer
>
[
https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4125:
---
Description:
For Processor API, user can get meta data like record offset, timestamp etc via
[
https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104122#comment-16104122
]
Matthias J. Sax commented on KAFKA-5660:
{{TopologyBuilderException}} got deprecated via KIP-120
[
https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5576:
---
Component/s: streams
> Support Power platform by updating rocksdb
>
[
https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5156:
--
Assignee: Matthias J. Sax (was: Eno Thereska)
> Options for handling exceptions in
Matthias J. Sax created KAFKA-5765:
--
Summary: Move merge() from StreamsBuilder to KStream
Key: KAFKA-5765
URL: https://issues.apache.org/jira/browse/KAFKA-5765
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5070.
Resolution: Duplicate
> org.apache.kafka.streams.errors.LockException: task [0_18] Failed
[
https://issues.apache.org/jira/browse/KAFKA-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5603:
---
Fix Version/s: (was: 0.11.0.2)
0.11.0.1
> Streams should not abort
[
https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5474:
---
Fix Version/s: (was: 0.11.0.0)
> Streams StandbyTask should no checkpoint on commit if
[
https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5474:
---
Affects Version/s: (was: 0.11.0.0)
0.11.1.0
> Streams StandbyTask
Matthias J. Sax created KAFKA-5485:
--
Summary: Streams should not suspend tasks twice
Key: KAFKA-5485
URL: https://issues.apache.org/jira/browse/KAFKA-5485
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16058103#comment-16058103
]
Matthias J. Sax commented on KAFKA-5488:
Thanks for creating this JIRA. I agree that the index
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4750:
---
Affects Version/s: (was: 0.10.1.1)
> KeyValueIterator returns null values
>
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4750:
---
Affects Version/s: 0.10.2.1
> KeyValueIterator returns null values
>
[
https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5510:
---
Description:
Currently, Streams commits only offsets of partitions it did process records
[
https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5510:
---
Description:
Currently, Streams commits only offsets of partitions it did process records
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062112#comment-16062112
]
Matthias J. Sax commented on KAFKA-4750:
Your observation is correct. I simplified the call chain.
[
https://issues.apache.org/jira/browse/KAFKA-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4262:
This happened again
[
https://issues.apache.org/jira/browse/KAFKA-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5464:
---
Fix Version/s: 0.11.1.0
> StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG
>
[
https://issues.apache.org/jira/browse/KAFKA-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5464:
---
Fix Version/s: 0.11.0.1
0.10.2.2
> StreamsKafkaClient should not use
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063956#comment-16063956
]
Matthias J. Sax commented on KAFKA-4750:
I think [~damianguy] or [~enothereska] can comment best
[
https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062424#comment-16062424
]
Matthias J. Sax commented on KAFKA-5145:
[~mingleizhang] Thanks for starting to contribute to
[
https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062423#comment-16062423
]
Matthias J. Sax commented on KAFKA-4750:
Sounds good to me.
> KeyValueIterator returns null
Matthias J. Sax created KAFKA-5474:
--
Summary: Streams StandbyTask should no checkpoint on commit if EOS
is enabled
Key: KAFKA-5474
URL: https://issues.apache.org/jira/browse/KAFKA-5474
Project:
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059527#comment-16059527
]
Matthias J. Sax commented on KAFKA-5488:
You can always start a discussion on the mailing list.
[
https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057842#comment-16057842
]
Matthias J. Sax commented on KAFKA-4857:
I meant was Ismael said. This Jira as intended to add a
Matthias J. Sax created KAFKA-5464:
--
Summary: StreamsKafkaClient should not use
StreamsConfig.POLL_MS_CONFIG
Key: KAFKA-5464
URL: https://issues.apache.org/jira/browse/KAFKA-5464
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165085#comment-16165085
]
Matthias J. Sax commented on KAFKA-5882:
I did have a look into the code, and don't understand how
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166549#comment-16166549
]
Matthias J. Sax commented on KAFKA-5882:
We actually do have system test for broker bounces. Thus,
[
https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168170#comment-16168170
]
Matthias J. Sax commented on KAFKA-5765:
Sure. If you need any help with the KIP, let us know.
[
https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5916:
---
Affects Version/s: 0.11.0.0
> Upgrade rocksdb dependency to 5.7.3
>
[
https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5765:
--
Assignee: Richard Yu
> Move merge() from StreamsBuilder to KStream
>
[
https://issues.apache.org/jira/browse/KAFKA-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5893:
---
Description:
{noformat}
java.lang.AssertionError: expected:<0> but was:<1>
at
[
https://issues.apache.org/jira/browse/KAFKA-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5893:
---
Description:
{noformat}
java.lang.AssertionError: expected:<0> but was:<1>
at
[
https://issues.apache.org/jira/browse/KAFKA-5893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5893:
---
Description:
{noformat}
java.lang.AssertionError: expected:<0> but was:<1>
at
[
https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170462#comment-16170462
]
Matthias J. Sax commented on KAFKA-5825:
[~apurva] Maybe you can provide some input here?
>
[
https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170564#comment-16170564
]
Matthias J. Sax commented on KAFKA-5825:
I just had one more look into your code. Maybe it's just
[
https://issues.apache.org/jira/browse/KAFKA-5937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5937:
---
Description:
We identified the follow issues:
- constructor calls
Matthias J. Sax created KAFKA-5958:
--
Summary: User StoreListener not available for global stores
Key: KAFKA-5958
URL: https://issues.apache.org/jira/browse/KAFKA-5958
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5949:
---
Description:
In Streams, we allow to register multiple user callbacks. We need to handle
[
https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177246#comment-16177246
]
Matthias J. Sax commented on KAFKA-5961:
[~agomez] Thanks for reporting this. Looking into this,
[
https://issues.apache.org/jira/browse/KAFKA-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5966:
---
Component/s: streams
> Support ByteBuffer serialization in Kafka Streams
>
[
https://issues.apache.org/jira/browse/KAFKA-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5489:
--
Assignee: Damian Guy (was: Matthias J. Sax)
> Failing test:
>
[
https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5225:
---
Labels: kip (was: needs-kip)
> StreamsResetter doesn't allow custom Consumer properties
>
[
https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169481#comment-16169481
]
Matthias J. Sax commented on KAFKA-5156:
A first overview of current exception handling can be
[
https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169520#comment-16169520
]
Matthias J. Sax commented on KAFKA-5156:
Thx. The doc is still WIP :)
> Options for handling
[
https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5876:
---
Labels: needs-kip newbie++ (was: needs-kip)
> IQ should throw different exceptions for
[
https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5660:
--
Assignee: Matthias J. Sax
> Don't throw TopologyBuilderException during runtime
>
[
https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5660:
---
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-5156
> Don't throw
[
https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4932:
---
Labels: newbie (was: )
> Add UUID Serde
> --
>
> Key: KAFKA-4932
[
https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4932:
---
Labels: needs-kip newbie (was: newbie)
> Add UUID Serde
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5765:
---
Labels: needs-kip newbie (was: needs-kip)
> Move merge() from StreamsBuilder to KStream
>
[
https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5158:
--
Assignee: Matthias J. Sax
> Options for handling exceptions during processing
>
[
https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5158:
---
Issue Type: Sub-task (was: New Feature)
Parent: KAFKA-5156
> Options for handling
[
https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5765:
---
Description:
Merging multiple {{KStream}} is done via {{StreamsBuilder#merge()}} (formally
1 - 100 of 5732 matches
Mail list logo
