Kafka Firehose shutdown()

Hey everyone.

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

Thanks

Marco

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:

http://imply.io/docs/latest/tutorial-kafka-indexing-service.html

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