Saya mulai belajar Kafka untuk tujuan solusi perusahaan. Selama pembacaan saya, beberapa pertanyaan muncul di benak saya: Ketika seorang produser memproduksi pesan - itu akan menentukan topik yang ingin dikirimi pesan, apakah itu benar? Apakah itu peduli dengan partisi? Ketika pelanggan berjalan...
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); Saat ini, saya mengirim pesan tanpa kunci apa pun sebagai bagian dari pesan kunci, apakah masih akan...
Saya baru-baru ini mulai belajar Kafka dan berakhir dengan pertanyaan-pertanyaan ini. Apa perbedaan antara Consumer dan Stream? Bagi saya, jika ada alat / aplikasi yang mengonsumsi pesan dari Kafka adalah konsumen di dunia Kafka. Apa perbedaan Stream karena ini juga menggunakan atau...
Saya menggunakan Confluent.Kafka .NET klien versi 1.3.0. Saya mengikuti dokumen : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId,...