[jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores

2016-05-26 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303428#comment-15303428 ] Henry Cai commented on KAFKA-3740: -- Looks like you want two sets of RocksDB settings, one for K/V store,

[jira] [Commented] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart

2016-06-21 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15343209#comment-15343209 ] Henry Cai commented on KAFKA-3890: -- PR: https://github.com/apache/kafka/pull/1538 > Kafka Streams: task

[jira] [Created] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart

2016-06-21 Thread Henry Cai (JIRA)
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

[jira] [Work started] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart

2016-06-21 Thread Henry Cai (JIRA)
[ 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

[jira] [Updated] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart

2016-06-21 Thread Henry Cai (JIRA)
[ 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

[jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores

2016-06-21 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15343115#comment-15343115 ] Henry Cai commented on KAFKA-3740: -- Yes, you or Roger can pick it up. > Add configs for RocksDBStores >

[jira] [Commented] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

2016-06-15 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15332649#comment-15332649 ] Henry Cai commented on KAFKA-3059: -- We would like to have the capability to move the offset to a certain

[jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-27 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352126#comment-15352126 ] Henry Cai commented on KAFKA-3904: -- I took a look at FileChannel.open, looks like it will still create a

[jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-27 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352387#comment-15352387 ] Henry Cai commented on KAFKA-3904: -- Please take a look at this PR for the fix:

[jira] [Updated] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-26 Thread Henry Cai (JIRA)
[ 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'

[jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-26 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350018#comment-15350018 ] Henry Cai commented on KAFKA-3904: -- I have the fix also: -FileChannel channel = new

[jira] [Created] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-26 Thread Henry Cai (JIRA)
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

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Created] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
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

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores

2016-05-20 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294310#comment-15294310 ] Henry Cai commented on KAFKA-3740: -- Worked now. > Add configs for RocksDBStores >

[jira] [Assigned] (KAFKA-3740) Add configs for RocksDBStores

2016-05-20 Thread Henry Cai (JIRA)
[ 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 > - > >

[jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores

2016-05-20 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294204#comment-15294204 ] Henry Cai commented on KAFKA-3740: -- You can assign this one to me. > Add configs for RocksDBStores >

[jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores

2016-05-20 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294270#comment-15294270 ] Henry Cai commented on KAFKA-3740: -- Don't see that 'assign' button > Add configs for RocksDBStores >

[jira] [Commented] (KAFKA-3185) Allow users to cleanup internal data

2016-05-02 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267619#comment-15267619 ] Henry Cai commented on KAFKA-3185: -- Second to this. It's very painful for us to test our demo program.

[jira] [Created] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2016-04-20 Thread Henry Cai (JIRA)
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

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

2016-04-20 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250977#comment-15250977 ] Henry Cai commented on KAFKA-3101: -- We really need this batching/buffering feature for us to adopt kafka

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Updated] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2016-04-20 Thread Henry Cai (JIRA)
[ 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

[jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-30 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358038#comment-15358038 ] Henry Cai commented on KAFKA-3904: -- This is a dup of KAFKA-3619 > File descriptor leaking (Too many open

[jira] [Resolved] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-30 Thread Henry Cai (JIRA)
[ 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

[jira] [Created] (KAFKA-8089) High level consumer from MirrorMaker is slow to deal with SSL certification expiration

2019-03-11 Thread Henry Cai (JIRA)
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

[jira] [Created] (KAFKA-12295) Shallow Mirroring

2021-02-04 Thread Henry Cai (Jira)
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:

[jira] [Created] (KAFKA-15620) Duplicate remote log DELETE_SEGMENT metadata is generated when there are multiple leader epochs in the segment

2023-10-17 Thread Henry Cai (Jira)
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: