jeqo opened a new pull request #11534:
URL: https://github.com/apache/kafka/pull/11534
Replacing for new Processor API where `@SuppressWarnings("deprecation") //
Old PAPI. Needs to be migrated.`
There are a few places where Processor Context is used and Processors could
not be fully migrated and will require other changes on the codebase:
`DeserializationExceptionHandler#handle`:
(not sure if this one requires a KIP to change)
```
@SuppressWarnings("deprecation") // Old PAPI. Needs to be migrated.
DeserializationHandlerResponse handle(final ProcessorContext context,
final ConsumerRecord<byte[],
byte[]> record,
final Exception exception);
```
`ProcessorParameters.oldProcessorSupplier` and `StatefulProcessorNode`:
```
public class ProcessorParameters<KIn, VIn, KOut, VOut> {
// During the transition to KIP-478, we capture arguments passed from
the old API to simplify
// the performance of casts that we still need to perform. This will
eventually be removed.
@SuppressWarnings("deprecation") // Old PAPI. Needs to be migrated.
private final org.apache.kafka.streams.processor.ProcessorSupplier<KIn,
VIn> oldProcessorSupplier;
```
```
// temporary hack until KIP-478 is fully implemented
@SuppressWarnings("deprecation") // Old PAPI. Needs to be migrated.
final org.apache.kafka.streams.processor.ProcessorSupplier<K, V>
oldProcessorSupplier =
processorParameters().oldProcessorSupplier();
if (oldProcessorSupplier != null && oldProcessorSupplier.stores() !=
null) {
for (final StoreBuilder<?> storeBuilder :
oldProcessorSupplier.stores()) {
topologyBuilder.addStateStore(storeBuilder, processorName);
}
}
```
and within tests:
- *TransformTest: include old `ProcessorContext`. This will require a new
Transformer API with new PAPI to change.
- ProcessorTopologyTest: contains test to validate old PAPI processors.
- MockProcessor/MockProcessorTest
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
