fede1024/rust-rdkafka
A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
RustMIT
Issues
- 0
oauth refresh method is sync
#727 opened by feniljain - 37
Upgrade from 0.34.0 to 0.36.0 causes consumer to stop consuming but keep running
#638 opened by zhrebicek - 4
Enable the development of custom consumers
#690 opened by manifest - 0
Rust MSRV may need to be updated
#720 opened by Abdullahsab3 - 0
libz missing when using with distroless
#719 opened by lcmgh - 1
- 0
Calling `assign` requires valid permissioned group.id even if no rebalance/offset management is required
#717 opened by c-campbell-mwam - 1
- 2
Nothing gets consumed from at_least_once example
#678 opened by miladamery - 2
Setting:bootstrap.servers doesn't work properly
#709 opened by echo-ethan - 3
- 3
`FutureProducer`'s `send` is slow when data is skewed
#695 opened by immno - 0
TopicPartitionList::elements violates unsafe precondition in slice::from_raw_parts_mut
#681 opened by hadronzoo - 4
Project Status: Is this still maintained?
#699 opened by pythops - 0
Question about waiting for rebalance callbacks
#701 opened by rhishikeshj - 0
- 1
- 0
rustls support
#693 opened by gitmalong - 1
No stats being printed to logs
#682 opened by coding-yogi - 3
How to batch insert headers?
#685 opened by funky-eyes - 1
how to use Dockerfile to build image of rust-kafka
#687 opened by uamself - 0
Unable to run example simple consumer
#684 opened by siddharthteli12 - 0
FromBytes impl for u8 should have no error case
#679 opened by Martoon-00 - 0
BaseProducer Poll and Flush no longer clearing queue after `Move to Event-based API` commit
#676 opened by brentmjohnson - 0
Fatal error: Local: Inconsistent state on FutureProducer with enable.idempotence = true
#630 opened by lurqui21 - 0
Failed compile with `cmake-build` on windows11
#675 opened by Xu-Mj - 1
- 2
KafkaError (Client config error: Unsupported value "snappy" for configuration property "compression.codec": snappy not enabled at buildtime compression.type snappy.)
#637 opened by 65001 - 0
Implement `std::convert::From<anyhow::Error>` for `rdkafka::error::KafkaError`
#670 opened by armantigranyan - 1
`StreamConsumer` not waking
#665 opened by trtt - 5
Emit kafka C library logs as tracing events
#663 opened by armantigranyan - 2
Add TLS support to rdkafka crate
#657 opened by rukai - 0
Client fails to reconnect to kafka once the kafka broker restarts or down and comes back up
#661 opened by manojnair727 - 1
- 0
How to ensure the consistency of offsets when closing
#656 opened by immno - 1
[Question] split_partition_queue behavior
#651 opened by Malefaro - 0
librdkafka returns some errors per partition
#654 opened by davidblewett - 5
memory appears to leak on consumer
#650 opened by leshow - 1
windows gnu toolchain compile err
#652 opened by Orca-bit - 3
`MessageStream` unfavourable interactions with `tokio`'s co-operative scheduling
#649 opened by tenuous-guidance - 0
`StreamConsumer::commit_message` with `OwnedMessage`
#643 opened by sagoez - 2
rust-rdkafka run error in Apple M1 Pro
#631 opened by bodypumper - 1
Can't use stream() from within spawn?
#642 opened by mindreader - 6
Mocking doesn't work
#629 opened by connormullett - 1
How to set BaseRecord key as none
#635 opened by siweilvxing - 0
- 0
Mocking consumer never exits
#633 opened by ETisREAL - 1
Needed minimal working example of Dockerfile
#625 opened by rdcm - 3
Committing in straming consumer
#626 opened by ETisREAL - 0
No access to consumer in rebalance callbacks
#627 opened by farico