Ошибка: librocksdbjni6770528225908825804.dll при объединении 2 потоков или при создании KTable в Kafka

Создание KStream из темы и возможность извлекать из нее данные. При попытке присоединиться к 2 потокам, созданным из разных тем, появляется следующая ошибка. Я получаю эту ошибку 1) при попытке создать KTable из темы или потока. 2) при объединении двух потоков.

Exception in thread "conferences-16397ea6-09e3-4e52-b5dc-2cdf0c830857-StreamThread-1" java.lang.UnsatisfiedLinkError: C:\Users\srikanth\AppData\Local\Temp\2\librocksdbjni6770528225908825804.dll: A dynamic link library (DLL) initialization routine failed
    at java.lang.ClassLoader$NativeLibrary.load(Native Method)
    at java.lang.ClassLoader.loadLibrary0(Unknown Source)
    at java.lang.ClassLoader.loadLibrary(Unknown Source)
    at java.lang.Runtime.load0(Unknown Source)
    at java.lang.System.load(Unknown Source)
    at org.rocksdb.NativeLibraryLoader.loadLibraryFromJar(NativeLibraryLoader.java:78)
    at org.rocksdb.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:56)
    at org.rocksdb.RocksDB.loadLibrary(RocksDB.java:64)
    at org.rocksdb.RocksDB.<clinit>(RocksDB.java:35)
    at org.rocksdb.Options.<clinit>(Options.java:25)

Погуглил и добавил следующую зависимость: compile group: 'org.rocksdb', name: 'rocksdbjni', version: '5.11.3', но не смог его преодолеть. Версия Kafka: confluentinc/cp-kafka-connect:4.1.0 Версия зависимости Kafka Stream: compile('org.apache.kafka:kafka-streams:1.0.1') Пробовал также с 1.0.0 и 1.1.0. Немногие блоги говорят, что это ошибка в версии, но я пробовал все 3 версии, и результат такой же. Помогите мне решить эту проблему.

Есть некоторые известные проблемы с Kafka Streams в WindowsOS, или, точнее, проблемы с RocksDB. Kafka Streams использует RockDB, но двоичные файлы RocksDB доступны не для всех версий WindowsOS. Лучше всего запустить Kafka Streams в среде Linux или попробовать другую версию WindowsOS.

Matthias J. Sax 29.05.2018 03:40

Пока вы не используете какие-либо операторы с отслеживанием состояния, Kafka Streams будет работать только в WindowsOS, потому что в этом случае он не использует RocksDB. Вы также можете заменить RocksDB хранилищем в памяти (поставляется с Kafka Streams), если вы не выполняете агрегирование / объединение в окнах (в настоящее время нет доступного из коробки хранилища окон в памяти)

Matthias J. Sax 29.05.2018 03:42
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
2
88
0

Другие вопросы по теме