Hi All,
I am using the Samza low level API and would like to be able to manipulate the
offsets for my Kafka input topics to be able to reprocess data from a previous
point in time.
It looks like the functionality to do this was introduced by SEP-18. Does
anyone know of any code example showin
https://issues.apache.org/jira/browse/SAMZA-2612
Raised a bug JIRA but wanted to check with the community. Any thoughts would be
great.
The StreamDescriptor class cannot accept all acceptable formats for Kafka Topic
names.
StreamDescriptor
private static final Pattern STREAM_ID_PATTERN =
Pa
