Каким образом вы интегрировали Apache Kafka в ваше Java-приложение?