V
Size: a a a
2020 November 20
V
похоже проперти в этом случае динамически формируются. Стартанул отдельно кафку с указанием server.properties
VG
как у сборки confluent изменить server.properties? Меняю тут etc/kafka/server.properties но в CONFLUENT_CURRENT есть только confluent.cLotZbBy/kafka/kafka.properties который каждый раз переписывается при старте и не содержит изменений из etc/kafka/server.properties
Не у компа сейчас, погляжу но вроде $Confluent_home/etc/server.properties должен работать
A
Подскажите, а upwork принимает сертификацию confluent по кафке?
IG
Объясните, почему в кафка-стримах используют лямбды на месте оъектов
Например
а в сигнатуре
groupBy(KeyValueMapper<? super K,? super V,KR> selector)
KeyValueMapper и его аналогов. Нигде не вижу, чтобы этот класс имплементил Runnalbe или что-то похожееНапример
.groupBy((key, word) -> word)
а в сигнатуре
groupBy(KeyValueMapper<? super K,? super V,KR> selector)
IG
ясно, я из другого языка.
IG
Да, я с другого языка, и поскольку столкнулся с этим в кафке, спросил здесь. Удивляет, что судя по обсуждению все знают, но никто не дал ответа.
IG
Хотя более-менее я уже нагуглил.