Skip to content

Commit

Permalink
Cut release 1.4.2
Browse files Browse the repository at this point in the history
  • Loading branch information
sevagh committed Feb 15, 2021
1 parent 7d5d288 commit d364f9e
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 7 deletions.
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "pq"
version = "1.4.2-rc0"
version = "1.4.2"
authors = ["Sevag Hanssian <[email protected]>"]
description = "jq for protobuf"
repository = "https://github.com/sevagh/pq"
Expand Down
5 changes: 1 addition & 4 deletions src/discovery.rs
Original file line number Diff line number Diff line change
Expand Up @@ -81,10 +81,7 @@ pub fn compile_descriptors_from_proto(proto_file: &str) -> PathBuf {

let output = cmd.output().expect("failed to execute protoc");
if !output.status.success() {
panic!(format!(
"protoc failed: {}",
String::from_utf8_lossy(&output.stderr)
));
panic!("protoc failed: {}", String::from_utf8_lossy(&output.stderr));
}

fdset_path
Expand Down
2 changes: 1 addition & 1 deletion stream-delimit/src/kafka_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ impl KafkaConsumer {
)
.with_topic(topic.to_owned())
.with_fallback_offset(fetch_offset)
.with_fetch_max_bytes_per_partition(1 * 1024 * 1024)
.with_fetch_max_bytes_per_partition(1024 * 1024)
.create()
{
Ok(consumer) => Ok(KafkaConsumer {
Expand Down

0 comments on commit d364f9e

Please sign in to comment.