hi, i met a strange issue, the same code running in a java class can consume
kafka , but when i change the java class to a spring bean(annotation is
@service) , the program can not consume kafka amymore. does anyone met the
similar problems or how can i debug this problems? thanks a lot
hi
i have a flink sql, reading record from kafka, then use table function do some
transformation, then produce to kafka.
i have found that in the flink web record received of the first subTask is
always 0 ,and the Records send of the last subTask is 0 as well.
i want to count how many r
退订
