Недостаточность проглатывания друидов kafka при анализе данных с помощью javascript

Question

У меня есть определенный формат сообщений в кафке. Они разделены. Теперь, чтобы разобрать это с помощью спокойствия, я использую ниже описание разбора.

 "parser" : { 
      "type" : "string", 
      "parseSpec" : { 
       "timestampSpec" : { 
       "column" : "datetime", 
       "format" : "yyyy-MM-dd HH:mm:ss" 
       }, 
       "dimensionsSpec" : { 
       "dimensions" : [], 
       "dimensionExclusions" : [ 
        "datetime" 
       ] 
       }, 
       "format" : "javascript", 
       "function" : "function(str) { var parts = str.split('^'); return { key1:parts[0],key2:parts[1],key3:parts[2] } }" 
      } 
      }, 

Однако, когда я вставляю линию через производителя кафки и проверяю журналы спокойствия. Он показывает droppedCount=1. Таким образом, это удаление сообщений. Я проверил выше функцию javascript в браузере. Он работает нормально. Что здесь может быть не так?

Answer 1

Я не думаю, что он поддерживает формат javascript.

Мой опыт Tranquility не поддерживает полный набор конфигураций друидов, в то время как в документе четко упоминается «spec - спецификация использования друидов без ioConfig» и ссылка на документ конфигурации друидов. Я потратил столько времени на нерабочую функцию. Я даже запустил его в отладчике, выполнив код, чтобы убедиться.

Я предлагаю Kafka extension, недавно добавленный в Друид. Тебе не нужно Спокойствие. Я считаю, что все форматы, поддерживаемые Друидом, будут работать с этим методом. Пожалуйста попробуйте.

Tranquility не обновлялся в течение длительного времени. Я предлагаю перейти к кормлению Кафкой.