KAFKA_PUBLISH is SHEDULED

[Utka7]

I am a novice developer and when working with conductor I ran into a problem. I am trying to send data to Kafka using system task (KAFKA_PUBLISH), but my status remains scheduled

{
      "name": "kafka_publish",
      "taskReferenceName": "kafka_publish",
      "inputParameters": {
        "kafka_request": {
          "maxBlockMs": 5000,
          "topic": "test-topic-for-TN-bot",
          "value": "${send_data_google_sheets.input.user_data}",
          "bootStrapServers": "kafka-dev.reliab.tech:9093",
          "headers": {},
          "key": "create_user",
          "keySerializer": "org.apache.kafka.common.serialization.StringSerializer",
          "valueSerializer": "org.springframework.kafka.support.serializer.JsonSerializer"
        }
      },
      "type": "KAFKA_PUBLISH",
      "startDelay": 0,
      "optional": false,
      "asyncComplete": false
    }`

[manan164]

Hi @Utka7 , You have to add Kafka dependency from the community into the server. Please add line, runtimeOnly group: 'com.netflix.conductor', name: 'conductor-kafka', version: '3.13.5' in server build.gradle