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

```norun use std::collections::HashMap; use mimalloc::MiMalloc; use crabkafka::{forwarder::ForwarderBuilder,Receiver,PartitionStrategies,CheckpointStrategies,TransformStrategies};

[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)) .checkpoint(CheckpointStrategies::OpenDoors) .partition(PartitionStrategies::newstickyroundrobin()) .transform(TransformStrategies::NoTransform) .kafkasettings(HashMap::from([("bootstrap.servers".toowned(),"broker:29091".toowned())])) .topic("testtopic".toowned()) .cachesize(1000) .statsinterval(10) .build() .unwrap() .await } ```

Examples

• UDP and DTLS example