THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public interface RecordContext {
String applicationId();
TaskId taskId();
StreamsMetrics metrics();
String topic();
int partition();
void commit();
long offset();
long timestamp();
Map<String, Object> appConfigs();
Map<String, Object> appConfigsWithPrefix(String prefix);
}
public interface ProcessorContext extends RecordContext {
// all methods but the ones in RecordContext
} |
...
Once we need a conversion from ProcessorContext
and RecordContext, we just cast:
...