crab_kafka

Forward + TLS traffic to kafka.

Based on tokio and rust rdkafka

Basic Usage

It's strongly encouraged the use of alternative allocator like MiMalloc ```

[global_allocator]

static GLOBAL: MiMalloc = MiMalloc;

[tokio::main]

async fn main() -> Result<(),String> { ForwarderBuilder::default() .receiver(Receiver::newtcpstream("127.0.0.1".toowned(), "8888".toowned(), 2000)) .checkpointstrategy(CheckpointStrategies::OpenDoors) .partitionstrategy(PartitionStrategies::newstickyroundrobin()) .transformstrategy(TransformerStrategies::NoTransform) .kafkasettings(HashMap::from([("bootstrap.servers".toowned(),"broker:29091".toowned())])) .outputtopic("testtopic".toowned()) .cachesize(1000) .statsinterval(10) .build() .unwrap() .await } ```

Examples

• UDP and DTLS example