Is there any mechanism in the kafka streaming source to specify the exact partition id that we want a streaming job to consume from?
If not, is there a workaround besides writing our a custom receiver? Thanks, - Alan
Is there any mechanism in the kafka streaming source to specify the exact partition id that we want a streaming job to consume from?
If not, is there a workaround besides writing our a custom receiver? Thanks, - Alan