как у сборки confluent изменить server.properties? Меняю тут etc/kafka/server.properties но в CONFLUENT_CURRENT есть только confluent.cLotZbBy/kafka/kafka.properties который каждый раз переписывается при старте и не содержит изменений из etc/kafka/server.properties
Не у компа сейчас, погляжу но вроде $Confluent_home/etc/server.properties должен работать
Объясните, почему в кафка-стримах используют лямбды на месте оъектов KeyValueMapper и его аналогов. Нигде не вижу, чтобы этот класс имплементил Runnalbe или что-то похожее
Например
.groupBy((key, word) -> word)
а в сигнатуре groupBy(KeyValueMapper<? super K,? super V,KR> selector)