File tree Expand file tree Collapse file tree 1 file changed +3
-22
lines changed Expand file tree Collapse file tree 1 file changed +3
-22
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,7 @@ use std::time::Duration;
1414#[ path = "utils/mod.rs" ]
1515mod utils;
1616
17+ /// Validates thast topics can be properly created.
1718#[ tokio:: test]
1819pub async fn test_topic_creation ( ) {
1920 init_test_logger ( ) ;
@@ -46,28 +47,8 @@ pub async fn test_topic_creation() {
4647 } ;
4748}
4849
49- #[ tokio:: test]
50- async fn test_topics ( ) {
51- init_test_logger ( ) ;
52-
53- // Get Kafka container context.
54- let kafka_context = KafkaContext :: shared ( )
55- . await
56- . expect ( "could not create kafka context" ) ;
57-
58- // Create admin client
59- let admin_client = utils:: admin:: create_admin_client ( & kafka_context. bootstrap_servers )
60- . await
61- . expect ( "could not create admin client" ) ;
62- let opts = AdminOptions :: new ( ) . operation_timeout ( Some ( Duration :: from_secs ( 30 ) ) ) ;
63-
64- // Create consumer client
65- let consumer_client =
66- utils:: consumer:: create_unsubscribed_base_consumer ( & kafka_context. bootstrap_servers )
67- . await
68- . expect ( "could not create consumer client" ) ;
69- }
70-
50+ /// Verify that topics are created as specified, and that they can later
51+ /// be deleted.
7152#[ tokio:: test]
7253pub async fn test_topic_create_and_delete ( ) {
7354 // Get Kafka container context.
You can’t perform that action at this time.
0 commit comments