Преобразование Kafka Connect не применяется - PullRequest
Новая
       6

Преобразование Kafka Connect не применяется

0 голосов
/ 17 декабря 2018

Я использую платформу Confluent с открытым исходным кодом.В настоящее время я сталкиваюсь с очень странным поведением - после добавления нового преобразования в исходный соединитель RabbitMQ поведение соединителя вообще не изменилось.

Это конфигурация: 

{
  "name": "rabbitmq-source",
  "connector.class": "com.github.jcustenborder.kafka.connect.rabbitmq.RabbitMQSourceConnector",
  "tasks.max": "1",
  "rabbitmq.host": "rabbitmq-server",
  "rabbitmq.queue": "my-queue",
  "kafka.topic": "my-topic",
  "transforms": "dropRabbitMqHeader,extractFields",
  "transforms.dropRabbitMqHeader.type": "transforms.rabbitmq.DropRabbitMqHeader$Value",
  "transforms.dropRabbitMqHeader.headers": "location",
  "transforms.extractFields.type": "transforms.ExtractFields$Value",
  "transforms.extractFields.fields":  "body,envelope.routingKey,basicProperties.headers",
  "transforms.extractFields.structName": "events"
}

Странно то, что я вижу сообщения журнала из метода configure DropRabbitMqHeader, но я не вижу сообщений журнала из метода apply.

Соединитель, кажется, простопропускаются.Но это не то, что мне нужно: я хочу, чтобы этот соединитель удалил некоторые заголовки из сообщения RabbitMQ и, наконец, сделал все извлечения.

...