Только у нового чехла магнит и он плохо влияет.

Но это все баловство, только мел и зеленое поле 👍

Или маркер и белое)

Тогда стилус в виде кия не вкатит 🤣

Всем привет!
Вопрос на ночь глядя, хотя я сам уже спать пошел
Как заставить работать кафка стриминг в режиме мультитрейдинга в ассинхронном режиме?
Например вот такой вот кусок кода:

val nConsumers: Int = 4
val consumerList: IndexedSeq[KafkaConsumer[String, String]] = Range(0, nConsumers).map(x => consumer)
while(true){
   val futuresList: List[Future[TrieMap[String, TrieMap[String, String]]]] = consumerList.map(x => Future{getKafkaData(resultMap, x)}).toList
   val listFutures: Future[List[TrieMap[String, TrieMap[String, String]]]] = Future.sequence(futuresList)
   Await.result(listFutures, concurentDuration("60 seconds"))
}

Причем запуская этот код в джупитере, я наблюдаю как он прекрасно работает, обгоняя сильно очень толстый по трафику топик, НО запуская этот же код в собранном джарнике ловлю ошибку что кафка не умеет в мультитрединге
java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

Привет, а кто какие либо для анализа и парсинга SQL использует, я обычно юзают JSqlParser. Но вдруг кто то знает получше что-то?
Задача простая попарсить не сколько сотен гигов SQL и вытащить от туда условия для where, в виде таблица  колонка значение

регулярки не достаточно?

кальцит не?

Кальцит уже будет слишком оверинженириг для этой задачи

Не, хочется потом иметь возможность расширять функционал, делать это на регулярках все равно что сразу себя в могилу закопать

ANTLR?

Грамматику описать дело двух минут, потом where_clause.getText()

Погляжу спасибо

какой движок?

Hive SQL. Мне их не надо ни где ранить или изобретать свой бэкенд, просто хочу сделать базовую аналитику. У меня миллиард команд кто использует данные я хочу для первого предложения посмотреть по каким полям и значениям они фильтруют

На гитхабе полно готовых грамматику если чё

Сейчас у меня не сколько сотен гигов SQL и идея взять JSqlParser прикрутить к спарку и попарсить все это быстренько

Ну вот LR парсер под это дело подходит. Флексом точно сложнее будет, на регулярках даже пытаться не стоит

Да я ещё не настолько безумен чтобы на регулярках такое писать

Напиши потом, как пройдет