scala - A non-blocking connection way in kafka -
first of all, i'm new on may explanation of problem not accurate.
i have topic in kafka data. consumer (written in scala) want connect server , consume information. problem think in executions consumer doesn't close , it's blocking reading.
i have followed this code.
how can create non-blocking connection read topic?
if need more details, please let me know.
Comments
Post a Comment