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: Bug
[
https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5779.
Resolution: Not A Problem
> Single message may exploit application based on KStream
> --
[
https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5786.
Resolution: Duplicate
> Yet another exception is causing that streamming app is zombie
> ---
Matthias J. Sax created KAFKA-5818:
--
Summary: Kafka Stream state transitions not correct
Key: KAFKA-5818
URL: https://issues.apache.org/jira/browse/KAFKA-5818
Project: Kafka
Issue Type: Bug
Matthias J. Sax created KAFKA-5823:
--
Summary: Update Docs
Key: KAFKA-5823
URL: https://issues.apache.org/jira/browse/KAFKA-5823
Project: Kafka
Issue Type: Sub-task
Reporter: Matt
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-3856.
Resolution: Fixed
> Cleanup Kafka Streams builder API
> -
>
Matthias J. Sax created KAFKA-5848:
--
Summary: KafkaConsumer should validate topics/TopicPartitions on
subscribe/assign
Key: KAFKA-5848
URL: https://issues.apache.org/jira/browse/KAFKA-5848
Project: K
Matthias J. Sax created KAFKA-5862:
--
Summary: Remove ZK dependency from Streams reset tool
Key: KAFKA-5862
URL: https://issues.apache.org/jira/browse/KAFKA-5862
Project: Kafka
Issue Type: Bu
Matthias J. Sax created KAFKA-5876:
--
Summary: IQ should throw different exceptions for different errors
Key: KAFKA-5876
URL: https://issues.apache.org/jira/browse/KAFKA-5876
Project: Kafka
I
Matthias J. Sax created KAFKA-5893:
--
Summary: ResetIntegrationTest fails
Key: KAFKA-5893
URL: https://issues.apache.org/jira/browse/KAFKA-5893
Project: Kafka
Issue Type: Bug
Compon
Matthias J. Sax created KAFKA-5936:
--
Summary: KafkaProducer should not wrap InterruptedException in
close() with KafkaException
Key: KAFKA-5936
URL: https://issues.apache.org/jira/browse/KAFKA-5936
P
Matthias J. Sax created KAFKA-5937:
--
Summary: Improve ProcessorStateManager exception handling
Key: KAFKA-5937
URL: https://issues.apache.org/jira/browse/KAFKA-5937
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-5948:
--
Summary: EosIntegrationTest fails with
TopicAlreadyMarkedForDeletionException
Key: KAFKA-5948
URL: https://issues.apache.org/jira/browse/KAFKA-5948
Project: Kafka
Matthias J. Sax created KAFKA-5949:
--
Summary: User Callback Exceptions need to be handled properly
Key: KAFKA-5949
URL: https://issues.apache.org/jira/browse/KAFKA-5949
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312250#comment-15312250
]
Matthias J. Sax commented on KAFKA-3775:
I have some concerns about this:
1) a KS
[
https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15322254#comment-15322254
]
Matthias J. Sax commented on KAFKA-3775:
I want to push this discussion further. A
[
https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15327326#comment-15327326
]
Matthias J. Sax commented on KAFKA-3775:
[~tenggyut] [~wushujames] Kafka Streams a
[
https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15328242#comment-15328242
]
Matthias J. Sax commented on KAFKA-3576:
I see two points:
(1) this is similar to
[
https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-3185:
--
Assignee: Matthias J. Sax
> Allow users to cleanup internal data
>
Matthias J. Sax created KAFKA-3880:
--
Summary: Disallow Join Windows with size zero
Key: KAFKA-3880
URL: https://issues.apache.org/jira/browse/KAFKA-3880
Project: Kafka
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/KAFKA-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3880:
---
Status: Patch Available (was: Open)
https://github.com/apache/kafka/pull/1529
> Disallow Joi
[
https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3429 stopped by Matthias J. Sax.
--
> Remove Serdes needed for repartitioning in KTable stateful operations
> ---
Matthias J. Sax created KAFKA-3936:
--
Summary: Validate user parameters as early as possible
Key: KAFKA-3936
URL: https://issues.apache.org/jira/browse/KAFKA-3936
Project: Kafka
Issue Type: I
[
https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3936:
---
Description:
Currently, parameters handed in by the user via public API, are not validated.
F
[
https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3478:
---
Description:
Today we have a event-time based flow control mechanism in order to synchronize
[
https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3185:
---
Status: Patch Available (was: Open)
> Allow users to cleanup internal data
>
Matthias J. Sax created KAFKA-3981:
--
Summary: Possible race condition between controller cache and ZK
on topic delete
Key: KAFKA-3981
URL: https://issues.apache.org/jira/browse/KAFKA-3981
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-3981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-3981.
Resolution: Not A Problem
> Possible race condition between controller cache and ZK on topic
Matthias J. Sax created KAFKA-4001:
--
Summary: Improving join semantics in Kafka Stremas
Key: KAFKA-4001
URL: https://issues.apache.org/jira/browse/KAFKA-4001
Project: Kafka
Issue Type: Bug
Matthias J. Sax created KAFKA-4008:
--
Summary: Module "tools" should ne be dependent on "core"
Key: KAFKA-4008
URL: https://issues.apache.org/jira/browse/KAFKA-4008
Project: Kafka
Issue Type:
Matthias J. Sax created KAFKA-4393:
--
Summary: Improve invalid/negative TS handling
Key: KAFKA-4393
URL: https://issues.apache.org/jira/browse/KAFKA-4393
Project: Kafka
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/KAFKA-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4393:
---
Description:
Currently, Kafka Streams does not handle invalid/negative timestamps returned
fr
[
https://issues.apache.org/jira/browse/KAFKA-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4393:
---
Description:
Currently, Kafka Streams does not handle invalid/negative timestamps returned
fr
[
https://issues.apache.org/jira/browse/KAFKA-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4393 started by Matthias J. Sax.
--
> Improve invalid/negative TS handling
>
[
https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4322:
---
Affects Version/s: (was: 0.10.0.1)
0.10.1.0
> StateRestoreCallback
[
https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4322:
---
Status: Patch Available (was: Open)
> StateRestoreCallback begin and end indication
> ---
[
https://issues.apache.org/jira/browse/KAFKA-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4393:
---
Status: Patch Available (was: In Progress)
> Improve invalid/negative TS handling
> -
Matthias J. Sax created KAFKA-4436:
--
Summary: Provide builder pattern for StreamsConfig
Key: KAFKA-4436
URL: https://issues.apache.org/jira/browse/KAFKA-4436
Project: Kafka
Issue Type: Impro
Matthias J. Sax created KAFKA-4437:
--
Summary: Incremental Batch Processing for Kafka Streams
Key: KAFKA-4437
URL: https://issues.apache.org/jira/browse/KAFKA-4437
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4437 started by Matthias J. Sax.
--
> Incremental Batch Processing for Kafka Streams
> --
[
https://issues.apache.org/jira/browse/KAFKA-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15703620#comment-15703620
]
Matthias J. Sax commented on KAFKA-4436:
bq. One of the goals in making KafkaStrea
[
https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4476 started by Matthias J. Sax.
--
> Kafka Streams gets stuck if metadata is missing
> -
Matthias J. Sax created KAFKA-4476:
--
Summary: Kafka Streams gets stuck if metadata is missing
Key: KAFKA-4476
URL: https://issues.apache.org/jira/browse/KAFKA-4476
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15716675#comment-15716675
]
Matthias J. Sax commented on KAFKA-4482:
Thanks for reporting. There is already a
[
https://issues.apache.org/jira/browse/KAFKA-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4482.
Resolution: Duplicate
> Kafka streams test failure and hang causing PR builds to fail
>
[
https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4476:
---
Status: Patch Available (was: In Progress)
> Kafka Streams gets stuck if metadata is missing
Matthias J. Sax created KAFKA-4499:
--
Summary: Add "getAllKeys" API for querying windowed KTable stores
Key: KAFKA-4499
URL: https://issues.apache.org/jira/browse/KAFKA-4499
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4509 started by Matthias J. Sax.
--
> Task reusage on rebalance fails for threads on same host
>
Matthias J. Sax created KAFKA-4509:
--
Summary: Task reusage on rebalance fails for threads on same host
Key: KAFKA-4509
URL: https://issues.apache.org/jira/browse/KAFKA-4509
Project: Kafka
Is
Matthias J. Sax created KAFKA-4510:
--
Summary: StreamThread must finish rebalance in state
PENDING_SHUTDOWN
Key: KAFKA-4510
URL: https://issues.apache.org/jira/browse/KAFKA-4510
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4510 started by Matthias J. Sax.
--
> StreamThread must finish rebalance in state PENDING_SHUTDOWN
>
[
https://issues.apache.org/jira/browse/KAFKA-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4510:
---
Status: Patch Available (was: In Progress)
> StreamThread must finish rebalance in state PEND
[
https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4509:
---
Status: Patch Available (was: In Progress)
> Task reusage on rebalance fails for threads on s
[
https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745672#comment-15745672
]
Matthias J. Sax commented on KAFKA-4437:
There is a mailing list thread... Just fo
[
https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4437 stopped by Matthias J. Sax.
--
> Incremental Batch Processing for Kafka Streams
> --
[
https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749636#comment-15749636
]
Matthias J. Sax commented on KAFKA-4540:
This makes sense. The problem is that
{{
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750030#comment-15750030
]
Matthias J. Sax commented on KAFKA-3856:
[~jeyhunkarimov] Are you still working on
[
https://issues.apache.org/jira/browse/KAFKA-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4582.
Resolution: Duplicate
> KStream job fails in multi-thread mode
> --
[
https://issues.apache.org/jira/browse/KAFKA-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15795551#comment-15795551
]
Matthias J. Sax commented on KAFKA-4582:
[~manudb9] Thanks for reporting! This sho
[
https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3856:
---
Labels: api needs-kip (was: api)
> Move inner classes accessible only functions in TopologyBu
[
https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3429:
---
Assignee: (was: Matthias J. Sax)
> Remove Serdes needed for repartitioning in KTable state
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15880966#comment-15880966
]
Matthias J. Sax commented on KAFKA-4791:
You should not call {{connectStateStoreNa
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15880971#comment-15880971
]
Matthias J. Sax commented on KAFKA-4791:
\cc [~damianguy]
> Kafka Streams - unabl
[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881339#comment-15881339
]
Matthias J. Sax commented on KAFKA-4601:
[~mihbor] Thanks for your comment. I gues
[
https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881456#comment-15881456
]
Matthias J. Sax commented on KAFKA-4791:
Ack. My bad. I thought [~clouTrix] calls
[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15887301#comment-15887301
]
Matthias J. Sax commented on KAFKA-4722:
[~sharad.develop] I left already a commen
[
https://issues.apache.org/jira/browse/KAFKA-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15887302#comment-15887302
]
Matthias J. Sax commented on KAFKA-4623:
[~sharad.develop]: [~ewencp] left already
[
https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15887304#comment-15887304
]
Matthias J. Sax commented on KAFKA-4706:
[~sharad.develop] You did close your PR.
[
https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15887309#comment-15887309
]
Matthias J. Sax commented on KAFKA-4738:
[~sharad.develop] Are you working on this
[
https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4815:
--
Assignee: Matthias J. Sax (was: Jason Gustafson)
> Idempotent/transactional Producer C
[
https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4815:
--
Assignee: (was: Matthias J. Sax)
> Idempotent/transactional Producer Checklist (KIP
[
https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4815:
--
Assignee: Jason Gustafson
> Idempotent/transactional Producer Checklist (KIP-98)
>
[
https://issues.apache.org/jira/browse/KAFKA-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4815:
---
Labels: kip (was: )
> Idempotent/transactional Producer Checklist (KIP-98)
>
[
https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888950#comment-15888950
]
Matthias J. Sax commented on KAFKA-4738:
[~sharad.develop] Your PR shows 81 commit
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4819:
---
Labels: needs-kip (was: )
> Expose states of active tasks to public API
> ---
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889006#comment-15889006
]
Matthias J. Sax commented on KAFKA-4819:
[~fhussonnois] Thanks for the JIRA an PR.
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4819:
--
Assignee: Florian Hussonnois
> Expose states of active tasks to public API
> --
[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889540#comment-15889540
]
Matthias J. Sax commented on KAFKA-4722:
Thanks for rebasing. I left a comment on
[
https://issues.apache.org/jira/browse/KAFKA-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4826:
---
Component/s: streams
> Fix some findbugs warnings in Kafka Streams
> -
[
https://issues.apache.org/jira/browse/KAFKA-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891031#comment-15891031
]
Matthias J. Sax commented on KAFKA-4677:
Streams used it's own partition assigner
[
https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891048#comment-15891048
]
Matthias J. Sax commented on KAFKA-4706:
Yes.
> Unify StreamsKafkaClient instance
[
https://issues.apache.org/jira/browse/KAFKA-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891151#comment-15891151
]
Matthias J. Sax commented on KAFKA-4828:
I am not sure if the JIRA title and error
[
https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4631:
--
Assignee: Rajini Sivaram (was: Matthias J. Sax)
> Refresh consumer metadata more frequ
[
https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4706:
---
Status: Patch Available (was: Open)
https://github.com/apache/kafka/pull/2631
> Unify Stream
[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4722:
---
Status: Patch Available (was: Open)
https://github.com/apache/kafka/pull/2617
> Add applicat
[
https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4738:
---
Status: Patch Available (was: Open)
> Remove generic type of class ClientState
>
[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894770#comment-15894770
]
Matthias J. Sax commented on KAFKA-4601:
Thanks!
> Avoid duplicated repartitionin
[
https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4830:
---
Labels: needs-kip newbie (was: newbie)
> Augment KStream.print() to allow users pass in extra
[
https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4830:
---
Description:
Today {{KStream.print}} use the hard-coded result string as:
{code}
"[" + this.s
[
https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894780#comment-15894780
]
Matthias J. Sax commented on KAFKA-4830:
Thank for tackling this!
Two comments: (
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4835:
---
Labels: needs-kip (was: )
> Allow users control over repartitioning
> ---
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894817#comment-15894817
]
Matthias J. Sax commented on KAFKA-4835:
I guess, we need API change for this, and
[
https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4842:
---
Component/s: streams
> Streams integration tests occasionally fail with connection error
> ---
[
https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897729#comment-15897729
]
Matthias J. Sax commented on KAFKA-3514:
[~mihbor] I am not sure about this. To me
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15898381#comment-15898381
]
Matthias J. Sax commented on KAFKA-4849:
With regard to http://docs.confluent.io/3
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4849:
--
Assignee: Matthias J. Sax
> Bug in KafkaStreams documentation
> ---
Matthias J. Sax created KAFKA-4857:
--
Summary: Improve Client handling
Key: KAFKA-4857
URL: https://issues.apache.org/jira/browse/KAFKA-4857
Project: Kafka
Issue Type: Bug
Component
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15898381#comment-15898381
]
Matthias J. Sax edited comment on KAFKA-4849 at 3/7/17 1:10 AM:
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4849:
---
Status: Patch Available (was: In Progress)
> Bug in KafkaStreams documentation
>
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4849 started by Matthias J. Sax.
--
> Bug in KafkaStreams documentation
> -
>
>
401 - 500 of 1684 matches
Mail list logo
