ER
может быть это странный кейс. Но если задуматься , встретит его каждый со временем. Я сейчас просто тестирую на базе Кафки 10ки разных flow , которые если смогу ею заменить , смогут сильно упростить дизайн системы.
Size: a a a
2020 November 03
ER
@gamussa Я прочитал документ с рекомендациями , который ты мне прислал. Могу прислать тебе в конце забега дополнительные настройки под kubernetes.
VG
Pasha
Хранилища делаю так:
KeyValueBytesStoreSupplier storeKeySupplier = Stores.inMemoryKeyValueStore(transactionsKeyStateStore);
StoreBuilder<KeyValueStore<String, Transaction>> storeKeyBuilder =
Stores.keyValueStoreBuilder(storeKeySupplier, stringSerde, transactionSerde).withLoggingDisabled();
KeyValueBytesStoreSupplier storeSupplier = Stores.persistentKeyValueStore(transactionsStateStore);
StoreBuilder<KeyValueStore<String, TransactionPerformance>> storeBuilder =
Stores.keyValueStoreBuilder(storeSupplier, stringSerde, transactionPerformanceSerde);
KeyValueBytesStoreSupplier storeKeySupplier = Stores.inMemoryKeyValueStore(transactionsKeyStateStore);
StoreBuilder<KeyValueStore<String, Transaction>> storeKeyBuilder =
Stores.keyValueStoreBuilder(storeKeySupplier, stringSerde, transactionSerde).withLoggingDisabled();
KeyValueBytesStoreSupplier storeSupplier = Stores.persistentKeyValueStore(transactionsStateStore);
StoreBuilder<KeyValueStore<String, TransactionPerformance>> storeBuilder =
Stores.keyValueStoreBuilder(storeSupplier, stringSerde, transactionPerformanceSerde);
Выведи TopologyDescription
VG
клиенты - мобильные приложения
да, нужно, если связь рвется, то надо дослать оставшееся на реконнекте клиента
да, нужно, если связь рвется, то надо дослать оставшееся на реконнекте клиента
А что за сообщения? Каждое сообщение важно? Или только последнее?
IZ
А что за сообщения? Каждое сообщение важно? Или только последнее?
Каждое важно! Это джсоны с апдейтами. (можно допустить дублирование, но не пропуск сообщения)
2020 November 04
P
Выведи TopologyDescription
Topologies:
Sub-topology: 0 for global store (will not generate tasks)
Source: transaction-source (topics: [first_topic])
--> transaction-key-processor
Processor: transaction-key-processor (stores: [transactions-key-state-store])
--> none
<-- transaction-source
Sub-topology: 0 for global store (will not generate tasks)
Source: transaction-source (topics: [first_topic])
--> transaction-key-processor
Processor: transaction-key-processor (stores: [transactions-key-state-store])
--> none
<-- transaction-source
lk
Доброе утро! Подскажите , чем пользуетесь для создания запросов в ksqldb. Есть ли какое-то ui, по типу ssms или datagrip в котором пользователю можно делать запросы , а не пользоваться рестом. Спасибо
Control Center / ksqldb cli
BB
Control Center / ksqldb cli
Благодарю.
2020 November 05
Z
привет всем, подскажите пожалуйста, настроил auth на кафка, сделал acl, все заработало, клиенты Кафки ходят по паролям в соответствии с настроеyными acl. Возник вопрос - а как теперь локально с кафка узла смотреть к примеру содержимое топика через - kafka-console-consumer?
Z
Его запускаю, а в логах ошибки вида:
Z
WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
Z
видимо при выполнении ./kafka-console-consumer надо как то предать логин пароль к доступам топиков? Каким образом это возможно сделать???
S
Zellox
видимо при выполнении ./kafka-console-consumer надо как то предать логин пароль к доступам топиков? Каким образом это возможно сделать???
Там был вроде ключ позволяющий задать путь к jaas конфигу с кредами
примерно так
--consumer.config=config/consumer.properties
примерно так
Z
Там был вроде ключ позволяющий задать путь к jaas конфигу с кредами
примерно так
--consumer.config=config/consumer.properties
примерно так
спасибо, а jaas уже внутри consumer.properties указывать?