Hi Anuj,
is that piece of code in your first mail in the same main? Then at this
point, nothing has been executed in Flink.
So we are looking at a normal Java programming error that you can easily
debug and unit test.
Most likely, there is no event config for *SEARCH_LIST_KEYLESS* or there is
a s
Hi Khachatryan,
This is the use case to create multiple streams:
I have a use case where multiple types of Avro records are coming in single
Kafka topic as we are suing TopicRecordNameStrategy for the subject in the
schema registry. Now I have written a consumer to read that topic and build
a Dat
As I understand from code, streamMap is a Java map, not Scala. So you can
get NPE while unreferencing the value you got from it.
Also, the approach looks a bit strange.
Can you describe what are you trying to achieve?
Regards,
Roman
On Mon, Feb 24, 2020 at 5:47 PM aj wrote:
>
> I am trying be
