[jira] [Commented] (SAMZA-951) Improve event loop timing metrics

[ https://issues.apache.org/jira/browse/SAMZA-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299227#comment-15299227 ] Yi Pan (Data Infrastructure) commented on SAMZA-951: Merged and submitted. Thanks! >

[jira] [Created] (SAMZA-952) Add validation for broadcast inputs configured for partitions that don't exist

Jake Maes created SAMZA-952: --- Summary: Add validation for broadcast inputs configured for partitions that don't exist Key: SAMZA-952 URL: https://issues.apache.org/jira/browse/SAMZA-952 Project: Samza

[jira] [Commented] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

[ https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298945#comment-15298945 ] Tao Feng commented on SAMZA-949: Got it. Thanks for the explanation. > KafkaCheckpointManager should not

[jira] [Commented] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

[ https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298927#comment-15298927 ] Yi Pan (Data Infrastructure) commented on SAMZA-949: [~TaoFeng], it is related but

[jira] [Commented] (SAMZA-949) KafkaCheckpointManager should not try forever for non-recoverable checkpoint deserialization failures

[ https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298921#comment-15298921 ] Tao Feng commented on SAMZA-949: Will fix for Samza-807 work for this? > KafkaCheckpointManager should not

[jira] [Commented] (SAMZA-856) Optionally automatically commit based on number of processed messages

[ https://issues.apache.org/jira/browse/SAMZA-856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297872#comment-15297872 ] Branislav Cogic commented on SAMZA-856: --- The patch is attached. Here is a RB link:

[jira] [Updated] (SAMZA-856) Optionally automatically commit based on number of processed messages

[ https://issues.apache.org/jira/browse/SAMZA-856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Branislav Cogic updated SAMZA-856: -- Attachment: SAMZA-856.0.patch > Optionally automatically commit based on number of processed