xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

update rust assignment

This commit is contained in:
sheyanjie-qq 2024-08-16 20:03:30 +08:00
parent 177112b659
commit a49ac1f2ec
2 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
docs/examples/rust/nativeexample/examples/tmq.rs
View File

@ -167,8 +167,9 @@ async fn main() -> anyhow::Result<()> {
let assignments = match consumer.assignments().await{ let assignments = match consumer.assignments().await{
Some(assignments) => assignments, Some(assignments) => assignments,
None => { None => {
eprintln!("Failed to get assignments."); let error_message = format!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id);
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id)); eprintln!("{}", error_message);
return Err(anyhow::anyhow!(error_message));
} }
}; };
println!("assignments: {:?}", assignments); println!("assignments: {:?}", assignments);
@ -209,8 +210,9 @@ async fn main() -> anyhow::Result<()> {
let assignments = match consumer.assignments().await{ let assignments = match consumer.assignments().await{
Some(assignments) => assignments, Some(assignments) => assignments,
None => { None => {
eprintln!("Failed to get assignments."); let error_message = format!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id);
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id)); eprintln!("{}", error_message);
return Err(anyhow::anyhow!(error_message));
} }
}; };
println!("After seek offset assignments: {:?}", assignments); println!("After seek offset assignments: {:?}", assignments);

10
docs/examples/rust/restexample/examples/tmq.rs
View File

@ -167,8 +167,9 @@ async fn main() -> anyhow::Result<()> {
let assignments = match consumer.assignments().await{ let assignments = match consumer.assignments().await{
Some(assignments) => assignments, Some(assignments) => assignments,
None => { None => {
eprintln!("Failed to get assignments."); let error_message = format!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id);
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id)); eprintln!("{}", error_message);
return Err(anyhow::anyhow!(error_message));
} }
}; };
println!("assignments: {:?}", assignments); println!("assignments: {:?}", assignments);
@ -209,8 +210,9 @@ async fn main() -> anyhow::Result<()> {
let assignments = match consumer.assignments().await{ let assignments = match consumer.assignments().await{
Some(assignments) => assignments, Some(assignments) => assignments,
None => { None => {
eprintln!("Failed to get assignments."); let error_message = format!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id);
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id)); eprintln!("{}", error_message);
return Err(anyhow::anyhow!(error_message));
} }
}; };
println!("After seek offset assignments: {:?}", assignments); println!("After seek offset assignments: {:?}", assignments);