Hello guys, please I need an urgent help, my http...
# general
o
Hello guys, please I need an urgent help, my http Sink Connector does not auto acknowledge, so when I restart the cluster it sends all the messages again, please how do I resolve this
Copy code
{
  "tenant": "public",
  "namespace": "default",
  "name": "k-test-msg",
  "className": "org.apache.pulsar.io.http.HttpSink",
  "sourceSubscriptionPosition": "Latest",
  "inputs": [
    "<persistent://public/default/test-msg>"
  ],
  "inputSpecs": {
    "<persistent://public/default/test-msg>": {
      "schemaProperties": {},
      "consumerProperties": {},
      "poolMessages": false,
      "regexPattern": false
    }
  },
  "configs": {
    "headers": {
      "webhook": "<https://webhook.site/753568bb-1ee7-4238-bc>",
      "webhook-custom-kph-Content-Type": "application/json"
    },
    "url": "<http://localhost:9000/webhook>"
  },
  "parallelism": 1,
  "processingGuarantees": "ATLEAST_ONCE",
  "retainOrdering": false,
  "retainKeyOrdering": false,
  "resources": {
    "cpu": 1,
    "ram": 1073741824,
    "disk": 10737418240
  },
  "autoAck": true,
  "archive": "<builtin://http>",
  "cleanupSubscription": true
}