Size: a a a

2019 December 26

AD

Alex Dev in pro.kafka
ну что там под C# kafka stream так и не завезли?
источник

λ

λλ in pro.kafka
через кафка утилитки как то можно стартануть для нескольких партиций 1 топика чтение с определенного таймстемпа ?
или надо коду пописать руками?
источник

D

Dauren in pro.kafka
Всем привет, я юзаю alpakka-kafka, у меня возникает проблема когда consumer читает сообщения, он доходит до какого-то сообщения и потом просто отправляет LeaveGroup request
источник

D

Dauren in pro.kafka
Из за чего это происходит?
источник

D

Dauren in pro.kafka
[INFO ] [26/12/2019 13:25:45] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Sending LeaveGroup request to coordinator 10.48.2.82:9092 (id: 2147483645 rack: null)
[INFO ] [26/12/2019 13:25:45] [akka://productProjector/system/kafka-consumer-1] a.a.RepointableActorRef | Message [akka.kafka.KafkaConsumerActor$Stop$] from Actor[akka://productProjector/system/StreamSupervisor-0/$$a#246015084] to Actor[akka://productProjector/system/kafka-consumer-1#1371580266] was not delivered. [1] dead letters encountered. If this is not an expected behavior, then [Actor[akka://productProjector/system/kafka-consumer-1#1371580266]] may have terminated unexpectedly, This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
источник

VG

Vik Gamov in pro.kafka
Alex Dev
ну что там под C# kafka stream так и не завезли?
Нет,  юзайте ksqldb
источник

K

KrivdaTheTriewe in pro.kafka
Vik Gamov
Нет,  юзайте ksqldb
я попвторю вопрос страшный, про приоритезацию очередей, есть ли что для нее, чтобы можноо преемптитьтопики было в ущерб другим или сильно замедлять их
источник

SP

Sergey Pichkurov in pro.kafka
KrivdaTheTriewe
я попвторю вопрос страшный, про приоритезацию очередей, есть ли что для нее, чтобы можноо преемптитьтопики было в ущерб другим или сильно замедлять их
если можно, конкретнее про use case ?
источник

K

KrivdaTheTriewe in pro.kafka
История следующая. Есть 2 Кафки. Одна очень критичная. Вторая нет.

Если их объединить, то в выигрыше все. Это единая точка интеграции и суммарно больше ресурсов.

Однако для критичных топиков желательно предусмотреть поведение чтобы при существенном росте нагрузки менее критичные топики выкашивались.

Например как в случае с очередями yarn
источник

SP

Sergey Pichkurov in pro.kafka
это, по идее, должно через квоты решаться?  https://cwiki.apache.org/confluence/display/KAFKA/KIP-257+-+Configurable+Quota+Management
источник
2019 December 27

S

Sergey in pro.kafka
Такой вопрос, а меня забанят, если я спаману сюда свой интересный канал про разработку?
источник

S

Sergey in pro.kafka
Ну и фидбека получить
источник

VG

Vik Gamov in pro.kafka
Sergey
Такой вопрос, а меня забанят, если я спаману сюда свой интересный канал про разработку?
А чем он интересный?
источник

S

Sergey in pro.kafka
Ну мне бы лично было интересно такое почитать
источник

S

Sergey in pro.kafka
Экстраполяция
источник

T

Tim in pro.kafka
Vik Gamov
А чем он интересный?
знать что таким болеют!)
источник

S

Sergey in pro.kafka
все девелоперы таким болеют в той или иной степени)
источник

VG

Vik Gamov in pro.kafka
Tim
знать что таким болеют!)
Забаню если не интересный канал будет
источник

VD

Vitalii Dmitriev in pro.kafka
Зачем это здесь?
источник

S

Sergey in pro.kafka
Ну вам жалко что-ли)
источник