Re: Replacing brokers in a cluster (0.8)

This seems like the type of behavior I'd ultimately want from the controlled shutdown tool . Currently, I believe the ShutdownBroker causes new leaders to be selected for any partition th

Re: Setting up kafka consumer to send logs to s3

I did the same search about a month ago. I forked this kafka-s3-consumer from QubitProducts/kafka-s3-consumer to upfit it for the 0.8 api changes. You'll have to futz with th