[jira] [Assigned] (KAFKA-10652) Raft leader should flush accumulated writes after a min size is reached

[ https://issues.apache.org/jira/browse/KAFKA-10652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-10652: - Assignee: Sagar Rao > Raft leader should flush accumulated writes after a min size is reached >

[jira] [Assigned] (KAFKA-10634) LeaderChangeMessage should include the leader as one of the voters

[ https://issues.apache.org/jira/browse/KAFKA-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-10634: - Assignee: Sagar Rao > LeaderChangeMessage should include the leader as one of the voters >

[jira] [Created] (KAFKA-10648) Add Prefix Scan support to State Stores

Sagar Rao created KAFKA-10648: - Summary: Add Prefix Scan support to State Stores Key: KAFKA-10648 URL: https://issues.apache.org/jira/browse/KAFKA-10648 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

[ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218723#comment-17218723 ] Sagar Rao commented on KAFKA-10603: --- Hey [~vvcephei], I know this task requires a unde

[jira] [Commented] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217271#comment-17217271 ] Sagar Rao commented on KAFKA-10616: --- Alright thanks [~ableegoldman], Let me know if we

[jira] [Commented] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217208#comment-17217208 ] Sagar Rao commented on KAFKA-10616: --- hey [~ableegoldman], Can I take this one up? > S

[jira] [Comment Edited] (KAFKA-10526) Explore performance impact of leader fsync deferral

[ https://issues.apache.org/jira/browse/KAFKA-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215353#comment-17215353 ] Sagar Rao edited comment on KAFKA-10526 at 10/16/20, 11:36 AM: ---

[jira] [Commented] (KAFKA-10526) Explore performance impact of leader fsync deferral

[ https://issues.apache.org/jira/browse/KAFKA-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215353#comment-17215353 ] Sagar Rao commented on KAFKA-10526: --- hey [~hachikuji], is it something that I can pick

[jira] [Commented] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209647#comment-17209647 ] Sagar Rao commented on KAFKA-10559: --- [~ableegoldman], i looked at the code today.. I s

[jira] [Commented] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208194#comment-17208194 ] Sagar Rao commented on KAFKA-10559: --- hey [~ableegoldman], I can pick this one if neede

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040766#comment-17040766 ] Sagar Rao commented on KAFKA-9168: -- hey [~ableegoldman] you had asked me to create this

[jira] [Created] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

Sagar Rao created KAFKA-9168: Summary: Integrate JNI direct buffer support to RocksDBStore Key: KAFKA-9168 URL: https://issues.apache.org/jira/browse/KAFKA-9168 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16854774#comment-16854774 ] Sagar Rao commented on KAFKA-7995: -- [~bchen225242] I see that there's an error called *I

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853054#comment-16853054 ] Sagar Rao commented on KAFKA-7995: -- Sure its sagarmeansoc...@gmail.com > Augment single

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851493#comment-16851493 ] Sagar Rao commented on KAFKA-7995: -- Hey [~suryateja...@gmail.com] apparently even I am n

[jira] [Assigned] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-7995: Assignee: Sagar Rao > Augment singleton protocol type to list for Kafka Consumer > -

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851007#comment-16851007 ] Sagar Rao commented on KAFKA-7206: -- I see. Probably I would also park it for now and loo

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848351#comment-16848351 ] Sagar Rao commented on KAFKA-7206: -- Hi [~shung] Thanks for sharing. I started going thro

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836852#comment-16836852 ] Sagar Rao commented on KAFKA-7206: -- Hi [~shung], [~guozhang] Is it something that I can

[jira] [Commented] (KAFKA-8238) Log how many bytes and messages were read from __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16829426#comment-16829426 ] Sagar Rao commented on KAFKA-8238: -- Thanks [~cmccabe]. I started looking at the code to

[jira] [Commented] (KAFKA-8238) Log how many bytes and messages were read from __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823168#comment-16823168 ] Sagar Rao commented on KAFKA-8238: -- Hi [~cmccabe] I am a new committer to Kafka project.

<    1   2   3   4   5