Size: a a a

2020 November 20

V

VladMl in pro.kafka
confluent local start
источник

VG

Vik Gamov in pro.kafka
Версия?
источник

V

VladMl in pro.kafka
5.5.1
источник

V

VladMl in pro.kafka
похоже проперти в этом случае динамически формируются. Стартанул отдельно кафку с указанием server.properties
источник

VG

Vik Gamov in pro.kafka
VladMl
как у сборки confluent изменить server.properties? Меняю тут etc/kafka/server.properties  но в CONFLUENT_CURRENT есть только confluent.cLotZbBy/kafka/kafka.properties  который каждый раз переписывается при старте и не содержит изменений из etc/kafka/server.properties
Не у компа сейчас, погляжу но вроде $Confluent_home/etc/server.properties должен работать
источник

A

Andrey in pro.kafka
Подскажите, а upwork принимает сертификацию confluent по кафке?
источник

IG

Ivan Grishaev in pro.kafka
Объясните, почему в кафка-стримах используют лямбды на месте оъектов KeyValueMapper и его аналогов. Нигде не вижу, чтобы этот класс имплементил Runnalbe или что-то похожее

Например
.groupBy((key, word) -> word)


а в сигнатуре
groupBy(KeyValueMapper<? super K,? super V,KR> selector)
источник

A

Alex in pro.kafka
А почему должен?
источник

A

Alex in pro.kafka
источник

A

Alex in pro.kafka
В случае scala примерно тот же подход
источник

VG

Vik Gamov in pro.kafka
Alex
А почему должен?
Присоединяюсь к вопросу
источник

VG

Vik Gamov in pro.kafka
Kafka streams работал ещё когда Java 8 не было в проде. Поэтому использовались свои интерфейсы
источник

IG

Ivan Grishaev in pro.kafka
ясно, я из другого языка.
источник

A

Alex in pro.kafka
Vik Gamov
Kafka streams работал ещё когда Java 8 не было в проде. Поэтому использовались свои интерфейсы
Ну он тоже следует политике Sam ;)
источник

A

Andrey in pro.kafka
Alex
А почему должен?
А это на мой вопрос ответ?
источник

A

Alex in pro.kafka
Andrey
А это на мой вопрос ответ?
Нет, на вопрос про runnable
источник

VG

Vik Gamov in pro.kafka
Давайте по порядку, зачем надо имплементировать Runnable?
источник

A

Alex in pro.kafka
Человек же сказал что из другого языка, поэтому возможно видел только инетрфей от екзекуторов, а там или runnable или callable

С функциональными интерфейсами и sam не сталкивался

Поэтому в принципе норм вопрос
источник

IG

Ivan Grishaev in pro.kafka
Да, я с другого языка, и поскольку столкнулся с этим в кафке, спросил здесь. Удивляет, что судя по обсуждению все знают, но никто не дал ответа.
источник

IG

Ivan Grishaev in pro.kafka
Хотя более-менее я уже нагуглил.
источник