e6229ce8bb
- always try checkpoint at least once (previously, a value of 0 retries meant it would never checkpoint) - setup record processor using New(), so we get default checkpointing configuration |
||
|---|---|---|
| .. | ||
| consumer | ||
e6229ce8bb
- always try checkpoint at least once (previously, a value of 0 retries meant it would never checkpoint) - setup record processor using New(), so we get default checkpointing configuration |
||
|---|---|---|
| .. | ||
| consumer | ||