Kafka Endpoint

package main

import loadstrike "loadstrike.com/sdk/go"

func main() {
    tracking := &loadstrike.TrackingConfigurationSpec{
        RunMode: "GenerateAndCorrelate",
        Source: &loadstrike.EndpointSpec{
            Kind:          "Kafka",
            Name:          "orders-in",
            Mode:          "Produce",
            TrackingField: "header:X-Correlation-Id",
            Kafka: &loadstrike.KafkaEndpointOptions{
                BootstrapServers: "localhost:9092",
                Topic:            "orders.in",
                SecurityProtocol: "SaslSsl",
                SASL: &loadstrike.KafkaSASLOptions{
                    Mechanism: "Plain",
                    Username:  "orders-user",
                    Password:  "orders-password",
                },
            },
        },
        Destination: &loadstrike.EndpointSpec{
            Kind:          "Kafka",
            Name:          "orders-out",
            Mode:          "Consume",
            TrackingField: "header:X-Correlation-Id",
            Kafka: &loadstrike.KafkaEndpointOptions{
                BootstrapServers: "localhost:9092",
                Topic:            "orders.completed",
                ConsumerGroupID:  "orders-tests",
            },
        },
    }

    loadstrike.RegisterScenarios(
        loadstrike.Empty("kafka-tracking").WithTrackingConfiguration(tracking),
    ).Run()
}

import com.loadstrike.runtime.CrossPlatformScenarioConfigurator;
import com.loadstrike.runtime.CrossPlatformTrackingConfiguration;
import com.loadstrike.runtime.KafkaEndpointDefinition;
import com.loadstrike.runtime.LoadStrikeCorrelation.TrackingFieldSelector;
import com.loadstrike.runtime.LoadStrikeRuntime.LoadStrikeRunner;
import com.loadstrike.runtime.LoadStrikeRuntime.LoadStrikeScenario;
import com.loadstrike.runtime.LoadStrikeRuntime.LoadStrikeSimulation;
import com.loadstrike.runtime.LoadStrikeTransports;

var source = new KafkaEndpointDefinition();
source.name = "orders-in";
source.mode = LoadStrikeTransports.TrafficEndpointMode.Produce;
source.trackingField = TrackingFieldSelector.parse("json:$.trackingId");
source.bootstrapServers = "localhost:9092";
source.topic = "orders.in";

var destination = new KafkaEndpointDefinition();
destination.name = "orders-out";
destination.mode = LoadStrikeTransports.TrafficEndpointMode.Consume;
destination.trackingField = TrackingFieldSelector.parse("json:$.trackingId");
destination.bootstrapServers = "localhost:9092";
destination.topic = "orders.out";
destination.consumerGroupId = "orders-tests";

var tracking = new CrossPlatformTrackingConfiguration();
tracking.source = source;
tracking.destination = destination;
tracking.runMode = LoadStrikeTransports.TrackingRunMode.GenerateAndCorrelate;

var scenario = CrossPlatformScenarioConfigurator.Configure(
    LoadStrikeScenario.empty("orders-kafka-to-kafka"),
    tracking
).withLoadSimulations(LoadStrikeSimulation.inject(10, 1d, 20d));

LoadStrikeRunner
    .registerScenarios(scenario)
    .withRunnerKey("rkl_your_local_runner_key")
    .run();

from loadstrike_sdk import CrossPlatformScenarioConfigurator, LoadStrikeRunner, LoadStrikeScenario, LoadStrikeSimulation

tracking = {
    "RunMode": "GenerateAndCorrelate",
    "Source": {
        "Kind": "Kafka",
        "Name": "orders-in",
        "Mode": "Produce",
        "TrackingField": "json:$.trackingId",
        "BootstrapServers": "localhost:9092",
        "Topic": "orders.in",
    },
    "Destination": {
        "Kind": "Kafka",
        "Name": "orders-out",
        "Mode": "Consume",
        "TrackingField": "json:$.trackingId",
        "BootstrapServers": "localhost:9092",
        "Topic": "orders.out",
        "ConsumerGroupId": "orders-tests",
    },
}

scenario = (
    CrossPlatformScenarioConfigurator.Configure(
        LoadStrikeScenario.empty("orders-kafka-to-kafka"),
        tracking,
    )
    .with_load_simulations(LoadStrikeSimulation.inject(10, 1, 20))
)

LoadStrikeRunner.register_scenarios(scenario) \
    .with_runner_key("rkl_your_local_runner_key") \
    .run()

import {
  CrossPlatformScenarioConfigurator,
  LoadStrikeRunner,
  LoadStrikeScenario,
  LoadStrikeSimulation
} from "@loadstrike/loadstrike-sdk";

const tracking = {
  RunMode: "GenerateAndCorrelate",
  Source: {
    Kind: "Kafka",
    Name: "orders-in",
    Mode: "Produce",
    TrackingField: "json:$.trackingId",
    BootstrapServers: "localhost:9092",
    Topic: "orders.in"
  },
  Destination: {
    Kind: "Kafka",
    Name: "orders-out",
    Mode: "Consume",
    TrackingField: "json:$.trackingId",
    BootstrapServers: "localhost:9092",
    Topic: "orders.out",
    ConsumerGroupId: "orders-tests"
  }
};

const scenario = CrossPlatformScenarioConfigurator
  .Configure(LoadStrikeScenario.empty("orders-kafka-to-kafka"), tracking)
  .withLoadSimulations(LoadStrikeSimulation.inject(10, 1, 20));

await LoadStrikeRunner
  .registerScenarios(scenario)
  .withRunnerKey("rkl_your_local_runner_key")
  .run();

const {
  CrossPlatformScenarioConfigurator,
  LoadStrikeRunner,
  LoadStrikeScenario,
  LoadStrikeSimulation
} = require("@loadstrike/loadstrike-sdk");

(async () => {
  const tracking = {
    RunMode: "GenerateAndCorrelate",
    Source: {
      Kind: "Kafka",
      Name: "orders-in",
      Mode: "Produce",
      TrackingField: "json:$.trackingId",
      BootstrapServers: "localhost:9092",
      Topic: "orders.in"
    },
    Destination: {
      Kind: "Kafka",
      Name: "orders-out",
      Mode: "Consume",
      TrackingField: "json:$.trackingId",
      BootstrapServers: "localhost:9092",
      Topic: "orders.out",
      ConsumerGroupId: "orders-tests"
    }
  };

  const scenario = CrossPlatformScenarioConfigurator
    .Configure(LoadStrikeScenario.empty("orders-kafka-to-kafka"), tracking)
    .withLoadSimulations(LoadStrikeSimulation.inject(10, 1, 20));

  await LoadStrikeRunner
    .registerScenarios(scenario)
    .withRunnerKey("rkl_your_local_runner_key")
    .run();
})();