Kafka Firehose shutdown()

Hey everyone.

Can anyone tell me how to call shutdown() on the build-in kafka firehose?



Hey Marco,

The kafka firehose doesn’t have a shutdown() method. What are you trying to accomplish?

Hey, I’m trying to force a handoff of segments. I’m using “none” as Retention Policy for testing. And I need a handoff.

Hi Marco, I think this tutorial might really help you:


You cannot set “none” rejection period and get handoff.