Patrik Kleindl created KAFKA-14128:
--
Summary: Kafka Streams terminates on topic check
Key: KAFKA-14128
URL: https://issues.apache.org/jira/browse/KAFKA-14128
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525714#comment-17525714
]
Patrik Kleindl commented on KAFKA-12909:
Your example actually seems wrong to me
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522148#comment-17522148
]
Patrik Kleindl commented on KAFKA-12909:
It makes sense but it is still kind of
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521492#comment-17521492
]
Patrik Kleindl commented on KAFKA-12909:
[~mjsax] My understanding was that Join
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518039#comment-17518039
]
Patrik Kleindl commented on KAFKA-12909:
[~mjsax] Is it planned to un-deprecate
Patrik Kleindl created KAFKA-13213:
--
Summary: StreamThread: State transition from PARTITIONS_ASSIGNED
to PARTITIONS_ASSIGNED
Key: KAFKA-13213
URL: https://issues.apache.org/jira/browse/KAFKA-13213
Pr
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035215#comment-17035215
]
Patrik Kleindl commented on KAFKA-8037:
---
[~ableegoldman] Interesting proposal.
At 2
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8037:
-
Assignee: (was: Patrik Kleindl)
> KTable restore may load bad data
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007020#comment-17007020
]
Patrik Kleindl commented on KAFKA-8037:
---
[~guozhang] I was about to ask in the thre
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984797#comment-16984797
]
Patrik Kleindl commented on KAFKA-7663:
---
[~vvcephei] [~ableegoldman] See my comment
[
https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl resolved KAFKA-8838.
---
Resolution: Not A Problem
> Allow consumer group tool to work with non-existing consumer grou
[
https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928395#comment-16928395
]
Patrik Kleindl commented on KAFKA-8838:
---
Thanks for making me re-check, it was a hu
[
https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl closed KAFKA-8838.
-
> Allow consumer group tool to work with non-existing consumer groups
> -
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921289#comment-16921289
]
Patrik Kleindl commented on KAFKA-5998:
---
Timeline for 2.4 is here
[https://cwiki.a
Patrik Kleindl created KAFKA-8838:
-
Summary: Allow consumer group tool to work with non-existing
consumer groups
Key: KAFKA-8838
URL: https://issues.apache.org/jira/browse/KAFKA-8838
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-8766:
--
Description:
Currently when starting a new streams application (= new consumer group) you
can
[
https://issues.apache.org/jira/browse/KAFKA-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913246#comment-16913246
]
Patrik Kleindl commented on KAFKA-8825:
---
[~hachikuji] It should help, but as our us
[
https://issues.apache.org/jira/browse/KAFKA-8825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16912575#comment-16912575
]
Patrik Kleindl commented on KAFKA-8825:
---
This would help indeed, linked my related
[
https://issues.apache.org/jira/browse/KAFKA-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909315#comment-16909315
]
Patrik Kleindl commented on KAFKA-8810:
---
We have encountered the same issue.
Witho
Patrik Kleindl created KAFKA-8766:
-
Summary: Allow a custom offset policy for Kafka Streams
applications
Key: KAFKA-8766
URL: https://issues.apache.org/jira/browse/KAFKA-8766
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-8024:
--
Fix Version/s: 2.4.0
> UtilsTest.testFormatBytes fails with german locale
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885284#comment-16885284
]
Patrik Kleindl commented on KAFKA-8024:
---
[~sujayopensource] You need to ask for per
[
https://issues.apache.org/jira/browse/KAFKA-8024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8024:
-
Assignee: Patrik Kleindl
> UtilsTest.testFormatBytes fails with german locale
>
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880565#comment-16880565
]
Patrik Kleindl commented on KAFKA-5998:
---
[~xmar] The timer starts running when the
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879027#comment-16879027
]
Patrik Kleindl commented on KAFKA-5998:
---
The cleanup is handled by a separate threa
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878549#comment-16878549
]
Patrik Kleindl edited comment on KAFKA-5998 at 7/4/19 10:57 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-5998:
--
Attachment: Kafka5998.zip
> /.checkpoint.tmp Not found exception
>
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878549#comment-16878549
]
Patrik Kleindl commented on KAFKA-5998:
---
As this is hopefully coming to an end than
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16874503#comment-16874503
]
Patrik Kleindl commented on KAFKA-5998:
---
I have started a Thread on Slack to report
[
https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870899#comment-16870899
]
Patrik Kleindl edited comment on KAFKA-6793 at 6/24/19 8:58 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871773#comment-16871773
]
Patrik Kleindl commented on KAFKA-7509:
---
Not related to Connect but giving this a b
[
https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870899#comment-16870899
]
Patrik Kleindl commented on KAFKA-6793:
---
Just to bump this, as discussed in
[https
[
https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8093:
-
Assignee: Matthias J. Sax (was: Patrik Kleindl)
> Fix JavaDoc markup
>
[
https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl resolved KAFKA-8093.
---
Resolution: Fixed
Fixed by other commits, see PR for discussion.
> Fix JavaDoc markup
>
[
https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836232#comment-16836232
]
Patrik Kleindl commented on KAFKA-8342:
---
This sounds very interesting, I hope it is
[
https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl closed KAFKA-8200.
-
> TopologyTestDriver should offer an iterable signature of readOutput
> -
[
https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl resolved KAFKA-8200.
---
Resolution: Won't Do
Discarded in favor of
[https://cwiki.apache.org/confluence/display/KAFK
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826493#comment-16826493
]
Patrik Kleindl commented on KAFKA-5998:
---
Found a new log, again starting with the m
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825821#comment-16825821
]
Patrik Kleindl commented on KAFKA-5998:
---
This issue was what led me to https://issu
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824514#comment-16824514
]
Patrik Kleindl commented on KAFKA-5998:
---
[~mjsax] If the state-cleaner ran and dele
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820523#comment-16820523
]
Patrik Kleindl commented on KAFKA-5998:
---
[~guozhang] Could you please share the dir
[
https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815152#comment-16815152
]
Patrik Kleindl commented on KAFKA-8200:
---
[~mjsax] I will do the write-up, please gi
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814291#comment-16814291
]
Patrik Kleindl commented on KAFKA-5998:
---
SUSE Linux Enterprise Server 12 SP3
4.4.1
[
https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813848#comment-16813848
]
Patrik Kleindl commented on KAFKA-8200:
---
[~mjsax] Does this require a KIP? I took t
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796490#comment-16796490
]
Patrik Kleindl commented on KAFKA-:
---
[~mjsax] In https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8093:
-
Assignee: Matthias J. Sax
[~mjsax]
Not able to reproduce locally with ./gradlew install
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787760#comment-16787760
]
Patrik Kleindl commented on KAFKA-7663:
---
I took a short look at this issue while wo
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787319#comment-16787319
]
Patrik Kleindl commented on KAFKA-8037:
---
Sorry for the mess, I thought I had to re-
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787240#comment-16787240
]
Patrik Kleindl commented on KAFKA-8037:
---
[~mjsax] [~guozhang]
Added [https://githu
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl reassigned KAFKA-8037:
-
Assignee: Patrik Kleindl
> KTable restore may load bad data
> --
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785420#comment-16785420
]
Patrik Kleindl commented on KAFKA-8037:
---
[~guozhang] Does that work too if LogAndCo
Patrik Kleindl created KAFKA-8024:
-
Summary: UtilsTest.testFormatBytes fails with german locale
Key: KAFKA-8024
URL: https://issues.apache.org/jira/browse/KAFKA-8024
Project: Kafka
Issue Type
Patrik Kleindl created KAFKA-8023:
-
Summary: Improve global state store restoration by using multiple
update threads
Key: KAFKA-8023
URL: https://issues.apache.org/jira/browse/KAFKA-8023
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778486#comment-16778486
]
Patrik Kleindl commented on KAFKA-7996:
---
[~mjsax] [~guozhang] Apologies for creatin
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777646#comment-16777646
]
Patrik Kleindl commented on KAFKA-7996:
---
You are right, I must haven taken a wrong
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777298#comment-16777298
]
Patrik Kleindl commented on KAFKA-7996:
---
>From a "user" perspective, if something i
Patrik Kleindl created KAFKA-7996:
-
Summary: KafkaStreams does not pass timeout when closing Producer
Key: KAFKA-7996
URL: https://issues.apache.org/jira/browse/KAFKA-7996
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771408#comment-16771408
]
Patrik Kleindl commented on KAFKA-5998:
---
[~guozhang] [~mjsax]
Not sure if it helps
[
https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739197#comment-16739197
]
Patrik Kleindl commented on KAFKA-6767:
---
[~guozhang] Thanks, a restart of the whole
[
https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16737510#comment-16737510
]
Patrik Kleindl commented on KAFKA-6767:
---
[~guozhang] Not sure if we are hitting the
[
https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712734#comment-16712734
]
Patrik Kleindl commented on KAFKA-7657:
---
[~guozhang] Thanks for the fast analysis.
[
https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711247#comment-16711247
]
Patrik Kleindl commented on KAFKA-7657:
---
[~guozhang]
{code:java}
2018-11-30 08:5
[
https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16710573#comment-16710573
]
Patrik Kleindl commented on KAFKA-7657:
---
[~guozhang]
I have tried to grab the rele
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708639#comment-16708639
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] Will do so when we do the next
[
https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706877#comment-16706877
]
Patrik Kleindl commented on KAFKA-7657:
---
[~guozhang] It seems we are seeing the sam
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704399#comment-16704399
]
Patrik Kleindl commented on KAFKA-7660:
---
Last question, who should "resolve" the Ji
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704395#comment-16704395
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] [~guozhang] I almost reported
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-7660:
--
Attachment: (was: heapdump-1543563004522_after.hprof)
> Stream Metrics - Memory Analysis
>
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-7660:
--
Attachment: heapdump-1543563004522_after.hprof
> Stream Metrics - Memory Analysis
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-7660:
--
Attachment: heapdump-1543441898901.hprof
> Stream Metrics - Memory Analysis
> -
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702422#comment-16702422
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] Well, at least that answers my
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701743#comment-16701743
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] Hi John
I tried applying the
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700100#comment-16700100
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] Thanks for confirming, glad I
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697511#comment-16697511
]
Patrik Kleindl commented on KAFKA-7660:
---
[~vvcephei] I can give you a small update:
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697057#comment-16697057
]
Patrik Kleindl commented on KAFKA-7660:
---
Hi [~vvcephei]
Thanks for taking a look.
Patrik Kleindl created KAFKA-7660:
-
Summary: Stream Metrics - Memory Analysis
Key: KAFKA-7660
URL: https://issues.apache.org/jira/browse/KAFKA-7660
Project: Kafka
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/KAFKA-7380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16674804#comment-16674804
]
Patrik Kleindl commented on KAFKA-7380:
---
The above link has a trailing period and d
Patrik Kleindl created KAFKA-7332:
-
Summary: Improve error message when trying to produce message
without key for compacted topic
Key: KAFKA-7332
URL: https://issues.apache.org/jira/browse/KAFKA-7332
Patrik Kleindl created KAFKA-7281:
-
Summary: Fix documentation and error message regarding
cleanup.policy=[compact,delete]
Key: KAFKA-7281
URL: https://issues.apache.org/jira/browse/KAFKA-7281
Project
79 matches
Mail list logo
