Kafka'ya yeni.Kafka 0.9 - java api ile bir konu nasıl oluşturulur
java-api'nin 0.9 sürümünde bir konu oluşturmak için nasıl kullanıldığını bulmakta zorlanıyor.
Bu answer 0,8 ile ilgileniyor.
Cluster'un bölüm bilgileri, konu vb. Sorgulama yöntemleri olduğunu görüyorum. Ancak dinamik olarak bir konu nasıl oluşturabileceğimi göremiyorum.
Kafka için, küme konuları nasıl oluşturabileceğinizi belirler. Anında konular oluşturabilmek istiyorsanız, en kolay yol kümenizde auto.create.topics.enable kullanmaktır. Daha sonra var olmayan bir konuya bir mesaj gönderdiğinizde, küme konuyu varsayılan önizleme bölümleri ve çoğaltma faktörüyle oluşturur. Bu özelliği etkinleştirmediyseniz/istemiyorsanız, Kafka istemcileri kitaplığında bildiğim yöntemler yoktur.
Eğer karar verirseniz, Kafka'nın çekirdek api ile konuları nasıl oluşturduğunu bulabileceğiniz internals of the kafka-topics.sh'a bakabilirsiniz.
Bu, sorusuna hiç cevap vermiyor. Ayrıca java api kullanarak konular yaratmayı da istemektedir, verdiğiniz link scalada yazılmıştır. –
Aslında bu soruya cevap veriyor, bunun için bir Java istemci API'si yok. Bunu yapan Scala admin API'sı var, ancak istemcilerde programatik olarak konular oluşturmak için Java API'sı yok, çünkü yalnızca yönetici özelliği/küme düzeyinde sağlanan bir şey olarak kullanılabilir. @GwenShapira beni bu konuda destekledi, bu yüzden sizi Kafka hakkında daha fazla okumaya davet ediyorum. Cevap şu şekildedir: A. Yapmıyorsunuz, kümenin yeni konulara otomatik olarak bir konuya yapmasını sağlıyorsunuz. Veya B. Scala'nın yalnızca yönetici API'sine dalmanız gerekir. PS, Scala sınıfları Java'dan kullanılabilir. –