Kafka has this interface which "gets" a `Processor<K,V>` ``` public interface ProcessorSuppli...

# announcements

[Shawn A]

Kafka has this interface which "gets" a Processor<K,V>

public interface ProcessorSupplier<K, V> {
    Processor<K, V> get();
}

Given I have a class:

class EventNotifier : Processor<String, SomeEvent>`

I thought I'd be able to
call the Kstream#process(ProcessorSupplier<? super K, ? super V> var1, String... var2) method, but I am getting
a type mismatch error for:

stream.process({ EventNotifier() })

[Shawn A]

>> Required: Processor<String!, SomeEvent!>!

Found: () -> EventNotifier

[karelpeeters]

Can you try forcing the SAM conversion?
stream.process(ProcessorSupplier { EventNotifier() })

[Shawn A]

@karelpeeters That works

[karelpeeters]

Strange, maybe report an issue.