[jira] [Created] (KAFKA-10410) OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place

Mark Shelton created KAFKA-10410: Summary: OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place Key: KAFKA-10410 URL: https://issues.apache.org/jira/browse/KAFKA-10410

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15716086#comment-15716086 ] Mark Shelton commented on KAFKA-4322: - I do not at all like the idea of using the metr

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715221#comment-15715221 ] Mark Shelton commented on KAFKA-4322: - >> "We tend not to have such callbacks" The St

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687516#comment-15687516 ] Mark Shelton commented on KAFKA-4322: - The logging is the same for us and logging fram

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15671564#comment-15671564 ] Mark Shelton commented on KAFKA-4322: - I have a custom store and processor and if no i

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665194#comment-15665194 ] Mark Shelton commented on KAFKA-4322: - >> Is there any particular reasons that you wan

[jira] [Commented] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord

[ https://issues.apache.org/jira/browse/KAFKA-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15654916#comment-15654916 ] Mark Shelton commented on KAFKA-4394: - Great thank you for the pointer. This is suffic

[jira] [Resolved] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord

[ https://issues.apache.org/jira/browse/KAFKA-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shelton resolved KAFKA-4394. - Resolution: Not A Problem > Processor API does not receive timestamp and/or ConsumerRecord >

[jira] [Created] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord

Mark Shelton created KAFKA-4394: --- Summary: Processor API does not receive timestamp and/or ConsumerRecord Key: KAFKA-4394 URL: https://issues.apache.org/jira/browse/KAFKA-4394 Project: Kafka

[jira] [Updated] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shelton updated KAFKA-4322: Flags: Patch > StateRestoreCallback begin and end indication > -

[jira] [Resolved] (KAFKA-4324) NullPointerException in StreamTask.forward

[ https://issues.apache.org/jira/browse/KAFKA-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shelton resolved KAFKA-4324. - Resolution: Invalid Marked as invalid. By accident my processor was singleton-like internally and

[jira] [Created] (KAFKA-4324) NullPointerException in StreamTask.forward

Mark Shelton created KAFKA-4324: --- Summary: NullPointerException in StreamTask.forward Key: KAFKA-4324 URL: https://issues.apache.org/jira/browse/KAFKA-4324 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4322) StateRestoreCallback begin and end indication

Mark Shelton created KAFKA-4322: --- Summary: StateRestoreCallback begin and end indication Key: KAFKA-4322 URL: https://issues.apache.org/jira/browse/KAFKA-4322 Project: Kafka Issue Type: Improve