Skip to content

Commit fc8b4f0

Browse files
committed
Allow -1 as orig_broker_id
After diving into the librdkafka source, this is a valid return value for metadata.orig_broker_id().
1 parent 473f8ff commit fc8b4f0

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

tests/test_metadata.rs

+6-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,12 @@ fn test_metadata() {
4040
let consumer = create_consumer(&rand_test_group());
4141

4242
let metadata = consumer.fetch_metadata(None, Duration::from_secs(5)).unwrap();
43-
assert_eq!(metadata.orig_broker_id(), 0);
43+
let orig_broker_id = metadata.orig_broker_id();
44+
// The orig_broker_id may be -1 if librdkafka's bootstrap "broker" handles
45+
// the request.
46+
if orig_broker_id != -1 && orig_broker_id != 0 {
47+
panic!("metadata.orig_broker_id = {}, not 0 or 1 as expected", orig_broker_id)
48+
}
4449
assert!(!metadata.orig_broker_name().is_empty());
4550

4651
let broker_metadata = metadata.brokers();

0 commit comments

Comments
 (0)