fix: commit and flush retry on other states (#4405)

* fix: commit and flush retry on other states * test: retry unit tests * chore: store fluvio client config instead itself
infinyon · Feb 22, 2025 · 20f2631 · 20f2631
1 parent fc15fe5
commit 20f2631
Show file tree

Hide file tree

Showing 4 changed files with 273 additions and 155 deletions.
diff --git a/crates/fluvio/src/consumer/mod.rs b/crates/fluvio/src/consumer/mod.rs
@@ -34,9 +34,12 @@ use crate::spu::{SpuDirectory, SpuSocketPool};
 
 pub use config::{ConsumerConfig, ConsumerConfigBuilder};
 pub use config::{ConsumerConfigExt, ConsumerConfigExtBuilder, OffsetManagementStrategy, RetryMode};
-pub use stream::{ConsumerStream, MultiplePartitionConsumerStream, SinglePartitionConsumerStream};
+pub use stream::{
+    ConsumerStream, MultiplePartitionConsumerStream, SinglePartitionConsumerStream,
+    ConsumerBoxFuture,
+};
 pub use offset::ConsumerOffset;
-pub use retry::ConsumerWithRetry;
+pub use retry::ConsumerRetryStream;
 
 pub use fluvio_protocol::record::ConsumerRecord as Record;
 pub use fluvio_spu_schema::server::smartmodule::SmartModuleInvocation;