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

Popular posts from this blog

php - Wordpress website dashboard page or post editor content is not showing but front end data is showing properly -

javascript - Get parameter of GET request -

javascript - Twitter Bootstrap - how to add some more margin between tooltip popup and element -