Какие методы можно применить для повышения производительности потоков обработки данных в Kafka?