kafka-topics --bootstrap-server localhost:9092 --partitions=3 --replication-factor=1 --create --topic tx-in 
kafka-topics --bootstrap-server localhost:9092 --partitions=3 --replication-factor=1 --create --topic tx-out

./transactions localhost:9092 tx-in tx-out

tansu_server::broker: 193: request=[0, 0, 0, 51, 0, 10, 0, 2, 0, 0, 0, 3, 0, 7, 114, 100, 107, 97, 102, 107, 97, 0, 31, 108, 105, 98, 114, 100, 107, 97, 102, 107, 97, 95, 116, 114, 97, 110, 115, 97, 99, 116, 105, 111, 110, 115, 95, 101, 120, 97, 109, 112, 108, 101, 1]
tansu_server::broker: 222: api_key=10 api_version=2 correlation_id=3
tansu_server::broker: 269: body=FindCoordinatorRequest { key: Some("librdkafka_transactions_example"), key_type: Some(1), coordinator_keys: None } correlation_id=3
tansu_server::broker: 359: key=Some("librdkafka_transactions_example") key_type=Some(1) coordinator_keys=None
tansu_server::broker: 227: body=FindCoordinatorResponse { throttle_time_ms: Some(0), error_code: Some(0), error_message: Some("NONE"), node_id: Some(4343), host: Some("127.0.0.1"), port: Some(9092), coordinators: None } correlation_id=3
tansu_server::broker: 199: response=[0, 0, 0, 35, 0, 0, 0, 3, 0, 0, 0, 0, 0, 0, 0, 4, 78, 79, 78, 69, 0, 0, 16, 247, 0, 9, 49, 50, 55, 46, 48, 46, 48, 46, 49, 0, 0, 35, 132]