[
https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899743#comment-15899743
]
Matthias J. Sax commented on KAFKA-4849:
[~habdank] Your Jira description says: "2
[
https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899823#comment-15899823
]
Matthias J. Sax commented on KAFKA-4437:
Kafka 0.10.2 got released already not con
[
https://issues.apache.org/jira/browse/KAFKA-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4859:
---
Component/s: streams
> Transient test failure:
> org.apache.kafka.streams.integration.JoinInt
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902014#comment-15902014
]
Matthias J. Sax commented on KAFKA-4222:
This did not occur anymore. Can we close
[
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-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905515#comment-15905515
]
Matthias J. Sax commented on KAFKA-4835:
If you use a custom partitioner that is s
[
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 get
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922911#comment-15922911
]
Matthias J. Sax commented on KAFKA-4835:
Agreed. I just wanted to point out, that
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924713#comment-15924713
]
Matthias J. Sax commented on KAFKA-4643:
\cc [~damianguy]
> Improve test coverag
[
https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926839#comment-15926839
]
Matthias J. Sax commented on KAFKA-3514:
Thanks for you input. It's an interesting
[
https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927000#comment-15927000
]
Matthias J. Sax commented on KAFKA-4905:
I am not sure if I can follow: What I don
[
https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927115#comment-15927115
]
Matthias J. Sax commented on KAFKA-4905:
I see. If you use the same app-id, all in
[
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 topic
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
C
[
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&focusedCommentId=15933935#comment-15933935
]
Matthias J. Sax commented on KAFKA-4921:
I am not sure if we need this. {{StreamPa
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: Improve
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936975#comment-15936975
]
Matthias J. Sax commented on KAFKA-4912:
I am actually not 100% sure -- I guess, i
[
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: KStreamKTableJoinInteg
[
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
*log
[
https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944329#comment-15944329
]
Matthias J. Sax commented on KAFKA-4960:
Thanks for reporting this. Can you give s
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 T
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945998#comment-15945998
]
Matthias J. Sax commented on KAFKA-4963:
Your observation is correct and the behav
[
https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946030#comment-15946030
]
Matthias J. Sax commented on KAFKA-4960:
Is it failing all the time? Or only occas
[
https://issues.apache.org/jira/browse/KAFKA-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947496#comment-15947496
]
Matthias J. Sax commented on KAFKA-4963:
I guess this would be possible to add int
[
https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949374#comment-15949374
]
Matthias J. Sax commented on KAFKA-4476:
That's a different issues, and we have a
[
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
> ---
[
https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949694#comment-15949694
]
Matthias J. Sax commented on KAFKA-4980:
PR: https://github.com/apache/kafka/pull/
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-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://github.com/apache
[
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-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 T
[
https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15951314#comment-15951314
]
Matthias J. Sax commented on KAFKA-4692:
[~original-brownbear] [~guozhang] Should
[
https://issues.apache.org/jira/browse/KAFKA-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15951626#comment-15951626
]
Matthias J. Sax commented on KAFKA-4988:
[~m...@vrischmann.me] This might be a Roc
[
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
>
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-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953717#comment-15953717
]
Matthias J. Sax commented on KAFKA-5002:
"if i start consumer which consumes data
[
https://issues.apache.org/jira/browse/KAFKA-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953736#comment-15953736
]
Matthias J. Sax commented on KAFKA-5003:
The PR from about is for {{trunk}} -- the
[
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
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-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4222.
Resolution: Fixed
> Transient failure in QueryableStateIntegrationTest.queryOnRebalance
> --
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4222:
> Transient failure in QueryableStateIntegrationTest.queryOnRebalance
>
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-4990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4990:
---
Status: Patch Available (was: Open)
> Add API stubs, config parameters, and request types
> -
[
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&focusedCommentId=15954476#comment-15954476
]
Matthias J. Sax commented on KAFKA-5004:
I did not know that this is by design --
[
https://issues.apache.org/jira/browse/KAFKA-5009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955544#comment-15955544
]
Matthias J. Sax edited comment on KAFKA-5009 at 4/4/17 6:16 PM:
[
https://issues.apache.org/jira/browse/KAFKA-5009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955544#comment-15955544
]
Matthias J. Sax commented on KAFKA-5009:
All topics generated by Kafka Streams are
[
https://issues.apache.org/jira/browse/KAFKA-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955739#comment-15955739
]
Matthias J. Sax commented on KAFKA-3455:
[~nthean] "I have done exactly this" -> y
[
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 Exact
[
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://cwiki.apache.org/confluence/display/KAFKA/KIP+130%3A+Expose+states+of+act
[
https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959761#comment-15959761
]
Matthias J. Sax commented on KAFKA-4831:
The classes `WindowSerializer` and `Windo
Matthias J. Sax created KAFKA-5037:
--
Summary: Infinite loop if all input topics are unknown at startup
Key: KAFKA-5037
URL: https://issues.apache.org/jira/browse/KAFKA-5037
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961105#comment-15961105
]
Matthias J. Sax commented on KAFKA-4927:
I guess, the PR got "forgotten" -- sorry
[
https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961152#comment-15961152
]
Matthias J. Sax commented on KAFKA-4927:
See Github comments -- just some nitpick.
[
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
> ---
[
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 KafkaStream
[
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 do
[
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
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-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967817#comment-15967817
]
Matthias J. Sax commented on KAFKA-5037:
A similar issue got reported here:
http:
[
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
> RocksDBSessionStoreSupplierTest#shouldNotBeLoggingEnabledStoreWhenLo
[
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 wi
[
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:
JoinIntegrationTest.testLeftKStreamKStr
[
https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969160#comment-15969160
]
Matthias J. Sax commented on KAFKA-5070:
[~dnagarajan] Thanks for report this issu
[
https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969163#comment-15969163
]
Matthias J. Sax commented on KAFKA-5071:
[~dnagarajan] Similar to KAFKA-5070 this
[
https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969171#comment-15969171
]
Matthias J. Sax commented on KAFKA-4912:
Thanks for contributing to Kafka [~soumab
[
https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4564:
---
Status: Patch Available (was: In Progress)
> When the destination brokers are down or misconf
[
https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-5073:
--
Assignee: Matthias J. Sax
> Kafka Streams stuck rebalancing after exception thrown in r
[
https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5073:
---
Status: Patch Available (was: Open)
> Kafka Streams stuck rebalancing after exception thrown
[
https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969595#comment-15969595
]
Matthias J. Sax commented on KAFKA-5073:
Thanks for pointing out [~ijuma]. I just
[
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}}
value
[
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-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4697:
---
Affects Version/s: (was: 0.10.2.0)
0.10.0.0
0
[
https://issues.apache.org/jira/browse/KAFKA-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4697:
---
Description:
Currently, deleting topics does not delete committed offsets. Thus, the reset
to
[
https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972048#comment-15972048
]
Matthias J. Sax commented on KAFKA-4772:
As you can see, there is already a PR for
[
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&focusedCommentId=15972983#comment-15972983
]
Matthias J. Sax commented on KAFKA-4755:
Patch for {{0.10.2}}: https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4842:
---
Description:
{noformat}
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reopened KAFKA-4222:
> Transient failure in QueryableStateIntegrationTest.queryOnRebalance
>
[
https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15973368#comment-15973368
]
Matthias J. Sax commented on KAFKA-4842:
[~edenhill] Your comment from above belon
Matthias J. Sax created KAFKA-5085:
--
Summary: Add test for rebalance exceptions
Key: KAFKA-5085
URL: https://issues.apache.org/jira/browse/KAFKA-5085
Project: Kafka
Issue Type: Bug
[
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: Imp
[
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://github.com/apache/ka
[
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-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 use
[
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,
{{enable.auto.co
[
https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:comment-tabpanel&focusedCommentId=15977190#comment-15977190
]
Matthias J. Sax commented on KAFKA-5096:
[~johnma] Thanks for picking up this Jira
[
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-5111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-5111 started by Matthias J. Sax.
--
> Improve internal Task APIs
> --
>
>
Matthias J. Sax created KAFKA-5111:
--
Summary: Improve internal Task APIs
Key: KAFKA-5111
URL: https://issues.apache.org/jira/browse/KAFKA-5111
Project: Kafka
Issue Type: Improvement
501 - 600 of 1684 matches
Mail list logo
