Skip to content

Commit

Permalink
Update out-of-date java client examples (#627)
Browse files Browse the repository at this point in the history
* update out-of-date java client examples

* Remove semaphore from AsyncSimpleConsumerExample

Signed-off-by: Aaron Ai <[email protected]>

---------

Signed-off-by: Aaron Ai <[email protected]>
Co-authored-by: Aaron Ai <[email protected]>
  • Loading branch information
kingkh1995 and aaron-ai committed Nov 6, 2023
1 parent 19a4afc commit 4b7c411
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,6 @@ public static void main(String[] args) throws ClientException, InterruptedExcept
Thread.sleep(Long.MAX_VALUE);
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
// producer.close();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,6 @@ public static void main(String[] args) throws ClientException {
}
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
// producer.close();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,6 @@ public static void main(String[] args) throws ClientException {
}
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
// producer.close();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,6 @@ public static void main(String[] args) throws ClientException {
}
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
// producer.close();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,6 @@ public static void main(String[] args) throws ClientException {

// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
// producer.close();
}
}

0 comments on commit 4b7c411

Please sign in to comment.