resource "plumber_tunnel" "my_replay_tunnel" {
name = "Tunnel to infra kafka"
# Obtained from your https://console.batch.sh account
batchsh_api_token = "batchsh_3b17c235a49a871d2c9715c80acdef33c9bfe6e1bc881a61f5659021eac9"
# Use our connection ID from earlier
connection_id = plumber_connection.my_kafka_server.id
# Start the relay immediately after creating
# Specify the kafka topic that messages will be written to when replaying to this tunnel
# Write the message with a key if needed
# Let's also specify kafka headers!