Replace AWS SQS & SNS with KubeMQ

Your AWS SDK (or an existing LocalStack-style setup) already talks SQS and SNS over HTTP — point its endpoint at KubeMQ and everything else — SDK, code, request shapes — stays the same.

Drop-in level: endpoint-only (legend)

1 · Enable the connector

The AWS connector is disabled by default — enable it and publish its port:

docker run -d \  --name kubemq \  -p 4566:4566 \  -p 50000:50000 \  -e KUBEMQ_TOKEN=YOUR_LICENSE_KEY \  -e CONNECTORS_AWS_ENABLE=true \  europe-docker.pkg.dev/kubemq/images/kubemq:next

Port 4566 is the AWS SDK endpoint_url / LocalStack-style convention (Connectors.Aws.Port on the client side) — not a fixed broker listener, so it doesn't appear in KubeMQ's shared port tables. That's not a typo.

2 · Point your client at KubeMQ

# No endpoint override; the SDK talks to the regional AWS endpoint.

export AWS_ENDPOINT_URL_SQS=http://localhost:4566
export AWS_ENDPOINT_URL_SNS=http://localhost:4566
export AWS_ACCESS_KEY_ID=test
export AWS_SECRET_ACCESS_KEY=test
export AWS_DEFAULT_REGION=us-east-1    # any value works; not enforced

Or override the endpoint per-client in boto3:

import boto3

sqs = boto3.client(
    "sqs",
    endpoint_url="http://localhost:4566",
    region_name="us-east-1",
    aws_access_key_id="test",
    aws_secret_access_key="test",
)

Dummy credentials are still required — the connector's accept-any mode doesn't verify the signature value, but the SDK must still form a syntactically valid SigV4 request.

3 · Smoke test

Adapted from the AWS connector's verification smoke test:

import boto3

sqs = boto3.client(
    "sqs",
    endpoint_url="http://localhost:4566",
    region_name="us-east-1",
    aws_access_key_id="test",
    aws_secret_access_key="test",
)

queue_url = sqs.create_queue(QueueName="smoke-test")["QueueUrl"]
sqs.send_message(QueueUrl=queue_url, MessageBody="smoke-test-payload")

resp = sqs.receive_message(QueueUrl=queue_url, WaitTimeSeconds=5)
msg = resp["Messages"][0]
assert msg["Body"] == "smoke-test-payload"
sqs.delete_message(QueueUrl=queue_url, ReceiptHandle=msg["ReceiptHandle"])
print("Smoke test PASSED.")

You should see:

Smoke test PASSED.

What carries over — and what doesn't

Your AWS SDK/CLI, code, and the SQS/SNS wire protocol carry over unchanged — only the endpoint moves. Existing queues/topics are not auto-migrated (recreate them against KubeMQ) and a few AWS features (SNS email/SMS/Lambda subscriptions, connector-side TLS) aren't supported — see the deviations list below.

Didn't work?