Fix shotover WARN logs caused by client disconnections
#1998Comparing
justinweng-instaclustr:1579-kafka-python-driver-creates-warnings-and-errors-in-shotover
(2c82746
) withmain
(62843e3
)0%
- Untouched
- 36
- Skipped
- 2
Benchmarks
38 total
encode_all
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec+5%
18.1 µs17.2 µs
decode_request_metadata_drop
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec+4%
2.4 µs2.4 µs
decode_request_produce_drop
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec+3%
3.2 µs3.1 µs
decode_request_list_offsets_drop
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec+2%
3 µs2.9 µs
decode_request_fetch_drop
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec+2%
3.2 µs3.2 µs
encode_request_fetch
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec0%
11.6 µs11.5 µs
valkey_filter
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
19.1 µs19.1 µs
encode_request_produce
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec0%
7.6 µs7.6 µs
encode_system.local_result_v5_lz4_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
200.1 µs200 µs
encode_system.local_result_v4_lz4_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
203.4 µs203.3 µs
nullsink
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
12.4 µs12.4 µs
loopback
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
5.6 µs5.6 µs
cassandra_request_throttling_unparsed
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
12 µs12 µs
valkey_cluster_ports_rewrite
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
15.9 µs15.9 µs
decode_system.local_query_v5_no_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
56.3 µs56.3 µs
cassandra_rewrite_peers_passthrough
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
79.9 µs79.9 µs
decode_system.local_query_v4_no_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
54.5 µs54.6 µs
decode_system.local_result_v4_lz4_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
45.7 µs45.8 µs
encode_system.local_result_v4_no_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
92.2 µs92.3 µs
query_counter_fresh
shotover/benches/benches/chain.rs::benches::criterion_benchmark::transform0%
15.1 µs15.1 µs
encode_request_metadata
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec0%
10.2 µs10.2 µs
decode_system.local_result_v4_no_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
12.4 µs12.4 µs
encode_system.local_query_v5_no_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
14 µs14 µs
decode_system.local_result_v5_lz4_compression
shotover/benches/benches/codec/cassandra.rs::benches::criterion_benchmark::cassandra_codec0%
46.4 µs46.5 µs
decode_request_fetch_create
shotover/benches/benches/codec/kafka.rs::benches::criterion_benchmark::kafka_codec0%
9.7 µs9.8 µs
Commits
Click on a commit to change the comparison rangeBase
main
62843e3
+0.25%
add int test to reproduce the warn logs
43bd9a2
9 hours ago
by justinweng-instaclustr-0.16%
handle tcp rst
2c82746
8 hours ago
by justinweng-instaclustr