Я пробовал что-то с частью кодирования, используя строки, и придумал код ниже, пожалуйста, помогите с проблемами синтаксиса с кодом.
KStreamBuilder builder = new KStreamBuilder();
KStream<String, String> textlines = builder.stream("INTOPIC");
KStream<String, String> mstream = textlines
.foreach(new ForeachAction<String, String>(){
public void apply(String key, String value){
String str=value.replace("[","");
for(int y=0; y<str.length(); y++){
//System.out.print(str.charAt(y));
}
//System.out.print("\n");
}
});
mstream.to("OUTTOPIC");
Во втором выражении KStream он показывает несовместимые типы..... Я хочу, чтобы логика замены работала, и она должна быть затронута переменной textlines. Заранее спасибо.
