Skip to content

Kafka Streams processor API context.forward

For incoming record I need to validate the value and based on result object I need to forward error to different topics and if successfully validated then forward the same using context.forward(). It can be done using DSL as provided in this link using kafka-streams to conditionally sort a json input stream I…

ZonedDateTime to Date before Java 8 in early Android

I am trying to replace the ZonedDateTime.toInstant method because it is only available since API 26 for Android. But my app is supposed to support API 19. I want to convert the ZonedDateTime to a Date so i can do something like this: What i want to achieve is the following: I want to calculate the difference …

Accessing spring bean proxy reference itself

I have an issue with @Cacheable and @CacheEviction annotations. When I call these methods in the bean where they are declared, the aop part is not getting executed. The underlying reason for this is that the bean access to its own instance itself, instead of accessing the spring proxy. I have read this questi…

Converting string to Map in java 8

Can someone please guide me on how to achieve the below using Java 8. I don’t know how to get that counter as the key Answer You can use IntStream to get this thing done. Use the integer value as the key, and the relevant value in the string array at that index as the value of the map. Another

Docker and jre 11 in Debug mode

I was trying to get a remote debug session running on my docker container. Actually the debug session always gets blocked by an IOException.. Dockerfile Entrypoint: Any ideas, whats wrong with this? Answer since java 9 you have to specify your adapter, or simply use an escaper for the debug host as such: grea…