Fix compilation issues with integration flags in connector tests.
@@ -339,7 +339,8 @@ impl TestPipeline {
#[cfg(any(
feature = "kafka-integration",
feature = "es-integration",
- feature = "s3-integration"
+ feature = "s3-integration",
+ feature = "tcp-integration"
))]
pub(crate) async fn get_contraflow(&self) -> Result<Event> {
match self.rx_cf.recv().timeout(Duration::from_secs(20)).await?? {
