Skip to content

Commit 40d0c8c

Browse files
committed
fix bug in super_stream_producer client created twice
1 parent 4abc07a commit 40d0c8c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/superstream_producer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ impl<T> SuperStreamProducerBuilder<T> {
117117

118118
let super_stream_metadata = DefaultSuperStreamMetadata {
119119
super_stream: super_stream.to_string(),
120-
client: self.environment.create_client().await?,
120+
client: client.clone(),
121121
partitions: Vec::new(),
122122
routes: Vec::new(),
123123
};

0 commit comments

Comments
 (0)