Henry Cai created KAFKA-15620:
-
Summary: Duplicate remote log DELETE_SEGMENT metadata is generated
when there are multiple leader epochs in the segment
Key: KAFKA-15620
URL: https://issues.apache.org/jira/browse/KAFKA
Henry Cai created KAFKA-12295:
-
Summary: Shallow Mirroring
Key: KAFKA-12295
URL: https://issues.apache.org/jira/browse/KAFKA-12295
Project: Kafka
Issue Type: Improvement
Components: con
Henry Cai created KAFKA-8089:
Summary: High level consumer from MirrorMaker is slow to deal with
SSL certification expiration
Key: KAFKA-8089
URL: https://issues.apache.org/jira/browse/KAFKA-8089
Project:
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai resolved KAFKA-3904.
--
Resolution: Duplicate
Dup of KAFKA-3619
> File descriptor leaking (Too many open files) for long runnin
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358038#comment-15358038
]
Henry Cai commented on KAFKA-3904:
--
This is a dup of KAFKA-3619
> File descriptor leakin
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352387#comment-15352387
]
Henry Cai commented on KAFKA-3904:
--
Please take a look at this PR for the fix:
https://g
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352126#comment-15352126
]
Henry Cai commented on KAFKA-3904:
--
I took a look at FileChannel.open, looks like it will
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350018#comment-15350018
]
Henry Cai commented on KAFKA-3904:
--
I have the fix also:
-FileChannel channel =
[
https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3904:
-
Description:
I noticed when my application was running long (> 1 day), I will get 'Too many
open files' e
Henry Cai created KAFKA-3904:
Summary: File descriptor leaking (Too many open files) for long
running stream process
Key: KAFKA-3904
URL: https://issues.apache.org/jira/browse/KAFKA-3904
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-3890 started by Henry Cai.
> Kafka Streams: task assignment is not maintained on cluster restart or
> rolling resta
[
https://issues.apache.org/jira/browse/KAFKA-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15343209#comment-15343209
]
Henry Cai commented on KAFKA-3890:
--
PR: https://github.com/apache/kafka/pull/1538
> Kafk
[
https://issues.apache.org/jira/browse/KAFKA-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3890:
-
Description:
Currently the task assignment in TaskAssignor is not deterministic. During
cluster restart
Henry Cai created KAFKA-3890:
Summary: Kafka Streams: task assignment is not maintained on
cluster restart or rolling restart
Key: KAFKA-3890
URL: https://issues.apache.org/jira/browse/KAFKA-3890
Project:
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15343115#comment-15343115
]
Henry Cai commented on KAFKA-3740:
--
Yes, you or Roger can pick it up.
> Add configs for
[
https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332649#comment-15332649
]
Henry Cai commented on KAFKA-3059:
--
We would like to have the capability to move the offs
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15303428#comment-15303428
]
Henry Cai commented on KAFKA-3740:
--
Looks like you want two sets of RocksDB settings, one
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294310#comment-15294310
]
Henry Cai commented on KAFKA-3740:
--
Worked now.
> Add configs for RocksDBStores
> --
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai reassigned KAFKA-3740:
Assignee: Henry Cai
> Add configs for RocksDBStores
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294270#comment-15294270
]
Henry Cai commented on KAFKA-3740:
--
Don't see that 'assign' button
> Add configs for Roc
[
https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294204#comment-15294204
]
Henry Cai commented on KAFKA-3740:
--
You can assign this one to me.
> Add configs for Roc
[
https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15267619#comment-15267619
]
Henry Cai commented on KAFKA-3185:
--
Second to this. It's very painful for us to test our
[
https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15250977#comment-15250977
]
Henry Cai commented on KAFKA-3101:
--
We really need this batching/buffering feature for us
[
https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3595:
-
Description:
Currently state store replication always go through a compact kafka topic. For
some state st
[
https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3596:
-
Description:
Currently in Kafka Streams, the way the windows are expired in RocksDB is
triggered by new e
[
https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3595:
-
Description:
Currently in Kafka Streams, the way the windows are expired in RocksDB is
triggered by new e
Henry Cai created KAFKA-3596:
Summary: Kafka Streams: Window expiration needs to consider more
than event time
Key: KAFKA-3596
URL: https://issues.apache.org/jira/browse/KAFKA-3596
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3595:
-
Description:
Currently state store replication always go through a compact kafka topic. For
some state s
[
https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3595:
-
Affects Version/s: (was: 0.9.0.1)
0.10.1.0
> Add capability to specify replicat
Henry Cai created KAFKA-3595:
Summary: Add capability to specify replication compact option for
stream store
Key: KAFKA-3595
URL: https://issues.apache.org/jira/browse/KAFKA-3595
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Cai updated KAFKA-3595:
-
Issue Type: Improvement (was: New Feature)
> Add capability to specify replication compact option for str
31 matches
Mail list logo
