Skip to content

Tag: consumer

Spring Kafka multiple topic for one class dynamically

I recently wanted to add a new behavior in my project that uses spring-kafka. The idea is really simple : App1 create a new scenario name “SCENARIO_1” and publish this string in the topic “NEW_SCENARIO” App1 publish some message on topic “APP2-SCENARIO_1” and “APP3-SCENARIO_1” App2 (group-id=app2) listens on NEW_SCENARIO and creates a new consumer<Object,String> listening on a new topic “APP2-SCENARIO_1”

How to throw an Exception in a Consumer Java 8

Is there any way to throw an Exception while using a consumer in java 8? For example: This gives me a compiler error saying: Unhandled exception type Exception What is the correct way to throw an exception in this case? Answer Since Exception and its subclass (other than RuntimeException) are checked Exception and in lambda, you can’t throw checked exception.

Does the JDK provide a dummy consumer?

I have a need in a block of code to consume ‘n’ items from a stream then finish, in essence: In my situation, I can’t change the signature to return Stream<T> and simply return stream.skip(n); I have to actually throw away some elements from the stream (not simple logic) – to be ready for a down stream consumer which doesn’t