LocationStratgies.PreferFixed in Structured Streaming

[Subacini Balakrishnan]

Hi,

We have a use case where specific kafka partition data needs to be assigned
to specific execuotr node.

In Spark Streaming, this can be achieved using
LocationStrategies.Preferfixed .How do we achieve same in structured
streaming??


*Spark Streaming*

Map<TopicPartition, String> partitionMapToHost = new HashMap<>();

partitionMapToHost.put(new TopicPartition("topic", 0), "node1");

partitionMapToHost.put(new TopicPartition("topic", 1), "node2");

partitionMapToHost.put(new TopicPartition("topic", 2), "node2");

 
KafkaUtils.createDirectStream(jssc,LocationStrategies.PreferFixed(partitionMapToHost),
 ConsumerStrategies.Subscribe(topicCollection, kafkaParams));



Regards,
Subacini