[
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=15795551#comment-15795551
]
Matthias J. Sax commented on KAFKA-4582:
[~manudb9] Thanks for reporting! This should be fixed
[
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-3745:
---
Labels: api needs-kip newbie (was: api newbie)
> Consider adding join key to ValueJoiner
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812244#comment-15812244
]
Matthias J. Sax commented on KAFKA-3745:
[~sree2k] thanks for picking this up. Just wanted to
[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812244#comment-15812244
]
Matthias J. Sax edited comment on KAFKA-3745 at 1/9/17 5:01 PM:
[~sree2k]
[
https://issues.apache.org/jira/browse/KAFKA-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15799096#comment-15799096
]
Matthias J. Sax commented on KAFKA-4436:
I guess we would need a KIP for this anyway -- should we
[
https://issues.apache.org/jira/browse/KAFKA-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15798809#comment-15798809
]
Matthias J. Sax commented on KAFKA-4582:
IIRC (and the JIRA also indicates it, as it is marked
[
https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949374#comment-15949374
]
Matthias J. Sax commented on KAFKA-4476:
That's a different issues, and we have a fix for this
[
https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949694#comment-15949694
]
Matthias J. Sax commented on KAFKA-4980:
PR: https://github.com/apache/kafka/pull/2757
>
[
https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4980:
---
Status: Patch Available (was: Open)
> testReprocessingFromScratch unit test failure
>
Matthias J. Sax created KAFKA-4990:
--
Summary: Add API stubs, config parameters, and request types
Key: KAFKA-4990
URL: https://issues.apache.org/jira/browse/KAFKA-4990
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4986:
---
Assignee: Matthias J. Sax
Status: Patch Available (was: Open)
[
https://issues.apache.org/jira/browse/KAFKA-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4986:
---
Description: Add new config parameter {{processing_guarantee}} and enable
"producer per task"
Matthias J. Sax created KAFKA-4986:
--
Summary: Add producer per task support
Key: KAFKA-4986
URL: https://issues.apache.org/jira/browse/KAFKA-4986
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4923 started by Matthias J. Sax.
--
> Add Exactly-Once Semantics
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4732:
--
Assignee: Guozhang Wang (was: Matthias J. Sax)
> Unstable test:
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15936975#comment-15936975
]
Matthias J. Sax commented on KAFKA-4912:
I am actually not 100% sure -- I guess, it depends how
Matthias J. Sax created KAFKA-4936:
--
Summary: Allow dynamic routing of output records
Key: KAFKA-4936
URL: https://issues.apache.org/jira/browse/KAFKA-4936
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947496#comment-15947496
]
Matthias J. Sax commented on KAFKA-4963:
I guess this would be possible to add into the API. If
[
https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946030#comment-15946030
]
Matthias J. Sax commented on KAFKA-4960:
Is it failing all the time? Or only occasionally? Do you
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945998#comment-15945998
]
Matthias J. Sax commented on KAFKA-4963:
Your observation is correct and the behavior is by
Matthias J. Sax created KAFKA-4969:
--
Summary: State-store workload-aware StreamsPartitionAssignor
Key: KAFKA-4969
URL: https://issues.apache.org/jira/browse/KAFKA-4969
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4953:
---
Description:
Currently it is not possible to initialise a global store with an in-memory
[
https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944329#comment-15944329
]
Matthias J. Sax commented on KAFKA-4960:
Thanks for reporting this. Can you give some more context
[
https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951314#comment-15951314
]
Matthias J. Sax commented on KAFKA-4692:
[~original-brownbear] [~guozhang] Should we close this as
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4912:
---
Description: We should check topic name length (if internal topics, and
maybe for source
Matthias J. Sax created KAFKA-4912:
--
Summary: Add check for topic name length
Key: KAFKA-4912
URL: https://issues.apache.org/jira/browse/KAFKA-4912
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4912:
---
Labels: newbie (was: )
> Add check for topic name length
> ---
>
Matthias J. Sax created KAFKA-4923:
--
Summary: Add Exactly-Once Semantics
Key: KAFKA-4923
URL: https://issues.apache.org/jira/browse/KAFKA-4923
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933935#comment-15933935
]
Matthias J. Sax commented on KAFKA-4921:
I am not sure if we need this.
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924713#comment-15924713
]
Matthias J. Sax commented on KAFKA-4643:
\cc [~damianguy]
> Improve test coverage of
[
https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927115#comment-15927115
]
Matthias J. Sax commented on KAFKA-4905:
I see. If you use the same app-id, all instances must be
[
https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15926839#comment-15926839
]
Matthias J. Sax commented on KAFKA-3514:
Thanks for you input. It's an interesting approach. We
[
https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927000#comment-15927000
]
Matthias J. Sax commented on KAFKA-4905:
I am not sure if I can follow: What I don't understand
Matthias J. Sax created KAFKA-5001:
--
Summary:
RocksDBSessionStoreSupplierTest#shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled
Key: KAFKA-5001
URL: https://issues.apache.org/jira/browse/KAFKA-5001
[
https://issues.apache.org/jira/browse/KAFKA-5004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5004:
---
Affects Version/s: 0.10.2.0
> poll() timeout not enforced when connecting to 0.10.0 broker
>
[
https://issues.apache.org/jira/browse/KAFKA-5004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954476#comment-15954476
]
Matthias J. Sax commented on KAFKA-5004:
I did not know that this is by design -- talked to
[
https://issues.apache.org/jira/browse/KAFKA-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4923:
---
Summary: Add Exactly-Once Semantics to Streams (was: Add Exactly-Once
Semantics)
> Add
[
https://issues.apache.org/jira/browse/KAFKA-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955739#comment-15955739
]
Matthias J. Sax commented on KAFKA-3455:
[~nthean] "I have done exactly this" -> you mean you did
Matthias J. Sax created KAFKA-5005:
--
Summary: JoinIntegrationTest.testLeftKStreamKStream() fails
occasionally
Key: KAFKA-5005
URL: https://issues.apache.org/jira/browse/KAFKA-5005
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4564 started by Matthias J. Sax.
--
> When the destination brokers are down or misconfigured in config, Streams
[
https://issues.apache.org/jira/browse/KAFKA-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5047:
---
Priority: Major (was: Trivial)
> NullPointerException while using GlobalKTable in
[
https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4564:
--
Assignee: Matthias J. Sax (was: Umesh Chaudhary)
> When the destination brokers are
[
https://issues.apache.org/jira/browse/KAFKA-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953736#comment-15953736
]
Matthias J. Sax commented on KAFKA-5003:
The PR from about is for {{trunk}} -- there is a second
[
https://issues.apache.org/jira/browse/KAFKA-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5003:
---
Fix Version/s: 0.11.0.0
Status: Patch Available (was: Open)
> StreamThread should
[
https://issues.apache.org/jira/browse/KAFKA-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953717#comment-15953717
]
Matthias J. Sax commented on KAFKA-5002:
"if i start consumer which consumes data from topic t1
Matthias J. Sax created KAFKA-5004:
--
Summary: poll() timeout not enforced when connecting to 0.10.0
broker
Key: KAFKA-5004
URL: https://issues.apache.org/jira/browse/KAFKA-5004
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955544#comment-15955544
]
Matthias J. Sax edited comment on KAFKA-5009 at 4/4/17 6:16 PM:
All topics
[
https://issues.apache.org/jira/browse/KAFKA-5009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955544#comment-15955544
]
Matthias J. Sax commented on KAFKA-5009:
All topics generated by Kafka Streams are prefixed with
[
https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4996:
---
Component/s: streams
> Fix findbugs multithreaded correctness warnings for streams
>
[
https://issues.apache.org/jira/browse/KAFKA-4995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4995:
---
Component/s: streams
> Fix remaining findbugs warnings in Kafka Streams
>
[
https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959761#comment-15959761
]
Matthias J. Sax commented on KAFKA-4831:
The classes `WindowSerializer` and `WindowDeserializer`
[
https://issues.apache.org/jira/browse/KAFKA-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-3455.
Resolution: Not A Problem
> Connect custom processors with the streams DSL
>
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4819:
---
Labels: kip (was: needs-kip)
> Expose states of active tasks to public API
>
[
https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4819:
---
Description:
[
https://issues.apache.org/jira/browse/KAFKA-5045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5045:
---
Labels: kip (was: )
> KTable materialization and improved semantics
>
Matthias J. Sax created KAFKA-5063:
--
Summary: Flaky
ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic
Key: KAFKA-5063
URL: https://issues.apache.org/jira/browse/KAFKA-5063
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4144:
---
Description:
At the moment the timestamp extractor is configured via a {{StreamConfig}}
[
https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4144:
---
Labels: api kip (was: api needs-kip)
> Allow per stream/table timestamp extractor
>
[
https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969595#comment-15969595
]
Matthias J. Sax commented on KAFKA-5073:
Thanks for pointing out [~ijuma]. I just double checked:
[
https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5005:
---
Description:
testLeftKStreamKStream:
{noformat}
java.lang.AssertionError: Condition not met
[
https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5005:
---
Summary: JoinIntegrationTest fails occasionally (was:
[
https://issues.apache.org/jira/browse/KAFKA-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5088:
---
Fix Version/s: 0.11.0.0
Status: Patch Available (was: Open)
> some spelling error
[
https://issues.apache.org/jira/browse/KAFKA-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5088:
--
Assignee: Xin
> some spelling error in code comment
>
[
https://issues.apache.org/jira/browse/KAFKA-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5090:
--
Assignee: Michal Borowiecki
> Kafka Streams SessionStore.findSessions javadoc broken
>
Matthias J. Sax created KAFKA-5096:
--
Summary: Check Streams user config parameter earlier
Key: KAFKA-5096
URL: https://issues.apache.org/jira/browse/KAFKA-5096
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5092:
---
Labels: kip (was: )
> KIP 141 - ProducerRecordBuilder Interface
>
[
https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4980:
Reopening this, as the fix should get cherry-picked to {{0.10.2}}:
[
https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5096:
---
Description:
Streams does not allow to overwrite some config parameters (eg,
[
https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977190#comment-15977190
]
Matthias J. Sax commented on KAFKA-5096:
[~johnma] Thanks for picking up this Jira. I just update
[
https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977190#comment-15977190
]
Matthias J. Sax edited comment on KAFKA-5096 at 4/20/17 6:18 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5096:
---
Summary: Only log invalid user configs and overwrite with correct one
(was: Check Streams
[
https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969163#comment-15969163
]
Matthias J. Sax commented on KAFKA-5071:
[~dnagarajan] Similar to KAFKA-5070 this might be fixed
[
https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15967817#comment-15967817
]
Matthias J. Sax commented on KAFKA-5037:
A similar issue got reported here:
[
https://issues.apache.org/jira/browse/KAFKA-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5001.
Resolution: Duplicate
>
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969160#comment-15969160
]
Matthias J. Sax commented on KAFKA-5070:
[~dnagarajan] Thanks for report this issue. It looks very
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15969171#comment-15969171
]
Matthias J. Sax commented on KAFKA-4912:
Thanks for contributing to Kafka [~soumabrata]! You got
[
https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4755:
---
Status: Patch Available (was: Reopened)
> SimpleBenchmark consume test fails for streams
>
[
https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15972983#comment-15972983
]
Matthias J. Sax commented on KAFKA-4755:
Patch for {{0.10.2}}:
[
https://issues.apache.org/jira/browse/KAFKA-5111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5111:
---
Status: Patch Available (was: In Progress)
> Improve internal Task APIs
>
[
https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5105:
---
Issue Type: Improvement (was: Bug)
> ReadOnlyKeyValueStore range scans are not ordered
>
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980030#comment-15980030
]
Matthias J. Sax commented on KAFKA-4912:
Thanks for the update!
> Add check for topic name length
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980034#comment-15980034
]
Matthias J. Sax commented on KAFKA-4849:
This PR seems to relate to this JIRA, too:
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980250#comment-15980250
]
Matthias J. Sax edited comment on KAFKA-5070 at 4/23/17 4:10 AM:
-
I had
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980250#comment-15980250
]
Matthias J. Sax commented on KAFKA-5070:
I had KAFKA-5038 in mind (not 100% sure though, if it is
[
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
[
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}
"[" +
[
https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15894780#comment-15894780
]
Matthias J. Sax commented on KAFKA-4830:
Thank for tackling this!
Two comments: (1) this JIRA is
[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15894770#comment-15894770
]
Matthias J. Sax commented on KAFKA-4601:
Thanks!
> Avoid duplicated repartitioning in KStream DSL
[
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=15894817#comment-15894817
]
Matthias J. Sax commented on KAFKA-4835:
I guess, we need API change for this, and thus, a KIP is
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905515#comment-15905515
]
Matthias J. Sax commented on KAFKA-4835:
If you use a custom partitioner that is solely based on
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902014#comment-15902014
]
Matthias J. Sax commented on KAFKA-4222:
This did not occur anymore. Can we close this for now?
>
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4222.
Resolution: Resolved
> Transient failure in QueryableStateIntegrationTest.queryOnRebalance
[
https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4848:
--
Assignee: Sachin Mittal
> Stream thread getting into deadlock state while trying to
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922911#comment-15922911
]
Matthias J. Sax commented on KAFKA-4835:
Agreed. I just wanted to point out, that there a
[
https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897729#comment-15897729
]
Matthias J. Sax commented on KAFKA-3514:
[~mihbor] I am not sure about this. To me it seems to be
[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15898381#comment-15898381
]
Matthias J. Sax commented on KAFKA-4849:
With regard to
301 - 400 of 1613 matches
Mail list logo
