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

Merge branch 'docs/sheyj-3.0' of github.com:taosdata/TDengine into docs/sheyj-3.0

This commit is contained in:
Yaming Pei 2024-08-16 20:11:51 +08:00
parent 5011a05e11 a49ac1f2ec
commit 17d784d584
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{
Some(assignments) => assignments,
None => {
eprintln!("Failed to get assignments.");
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id));
let error_message = format!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id);
eprintln!("{}", error_message);
return Err(anyhow::anyhow!(error_message));
}
};
println!("assignments: {:?}", assignments);
@ -209,8 +210,9 @@ async fn main() -> anyhow::Result<()> {
let assignments = match consumer.assignments().await{
Some(assignments) => assignments,
None => {
eprintln!("Failed to get assignments.");
return Err(anyhow::anyhow!("Failed to get assignments. topic: {}, groupId: {}, clientId: {}", topic, group_id, client_id));
let error_message = format!("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);

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