private static final Log log = LogFactory.getLog(PlacementStrategyManager.class);
private final FrameworkState frameworkState;
PlacementStrategyManager(FrameworkState frameworkState) {
this.frameworkState = frameworkState;
}
<BUG>public Optional<PlacementRuleGenerator> getPlacementStrategy(
KafkaSchedulerConfiguration config,</BUG>
Protos.TaskInfo taskInfo) {
String placementStrategy = config.getServiceConfiguration().getPlacementStrategy();
log.info("Using placement strategy: " + placementStrategy);

private static final Log log = LogFactory.getLog(PlacementStrategyManager.class);
private final FrameworkState frameworkState;
PlacementStrategyManager(FrameworkState frameworkState) {
this.frameworkState = frameworkState;
}
public Optional<PlacementRule> getPlacementStrategy(
KafkaSchedulerConfiguration config,
Protos.TaskInfo taskInfo) {
String placementStrategy = config.getServiceConfiguration().getPlacementStrategy();
log.info("Using placement strategy: " + placementStrategy);
