Kafka has this interface which gets a `Processor lt K V gt ` ``` public interface ProcessorSupplier lt K V gt Processor lt K V gt get ``` Given I have a class ``` class EventNotifier Processor lt String SomeEvent gt ` ``` I thought I d be able to call the `Kstream process ProcessorSupplier lt super K super V gt var1 String var2 ` method but I am getting a type mismatch error for ``` stream process EventNotifier ```

gt gt gt Required Processor lt String SomeEvent gt Found gt EventNotifier

Kafka has this interface which gets a `Processor lt K V gt ` kotlinlang #announcements

06/03/2019, 3:15 PM

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() })

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

Found: () -> EventNotifier

karelpeeters

06/03/2019, 3:23 PM

Can you try forcing the SAM conversion?

stream.process(ProcessorSupplier { EventNotifier() })

06/03/2019, 3:32 PM

@karelpeeters That works

karelpeeters

06/03/2019, 3:32 PM

Strange, maybe report an issue.