Публикация UDP-фида в теме Kafka через Syslog Connector в Confluent Kafka Connect - PullRequest
Новая
       7

Публикация UDP-фида в теме Kafka через Syslog Connector в Confluent Kafka Connect

0 голосов
/ 08 июня 2019
  • Я создаю UDP-фид для порта 5514 , используя nc 127.0.0.1 5514 -u -v
  • Я использую конфлюэнтную версию сообщества 5.2.1

  • Iтакже установлен kafka connect syslog версия 1.2.6

  • Ниже приведены конфигурации для моего разъема системного журнала 

name=syslog    
tasks.max=1
connector.class=io.confluent.connect.syslog.SyslogSourceConnector    
syslog.port=5514    
syslog.listener=UDP    
topic=udptest    
confluent.license=
confluent.topic.bootstrap.servers=127.0.0.1:9092  
confluent.topic.replication.factor=1
  • Затем я начал сливаться, используя /Users/dineth/Documents/confluent/bin/confluent start

  • Создал тему kafka, используя /Users/dineth/Documents/confluent/bin/kafka-topics --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic udptest

  • После этого язагрузил соединитель, используя /Users/dineth/Documents/confluent/bin/confluent load syslog -d /Users/dineth/Documents/confluent/share/confluent-hub-components/confluentinc-kafka-connect-syslog/etc/minimal-udp.properties

  • Затем я запустил kafka-console-consumer, используя /Users/dineth/Documents/confluent/bin/kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic udptest --from-beginning

  • Когда я подаю что-то в порт 5514через UDP консоль ничего не отображает.

  • Но когда я пытаюсь создать некоторую строку непосредственно для kafka-console -roduction и пытаться использовать ее из того же самого выше созданноготопик, работает нормально.

...