apache-kafka - Spring Kafka Streams Binder - 批处理和重试

Question

我已经阅读了一堆 Spring Cloud Stream Kafka Streams Binder 笔记，但我无法看到如何执行 2 件事：

1. 我将如何进行批处理，比如说使用 Kafka Streams Binder 一次处理 100 条记录？

2. 常规的 kafka binder 有 SeekToCurrentBatchHandler 和 SeekToCurrentErrorHandler，我该如何在 Kafka Streams 中调用这些函数？

标签： apache-kafkaspring-cloud-streamspring-cloud-stream-binder-kafka