Saya menggunakan Spring Cloud Stream (SCS) dengan Kafka sebagai pengikat.

Saya ingin melakukan pemfilteran tingkat rendah pada catatan berdasarkan header Kafka. Apa pendekatan yang direkomendasikan?

Pesan yang difilter harus diabaikan dan offset harus dilakukan.

Saya sedang berpikir untuk mengonfigurasi RecordFilterStrategy.

0
Abbadon 12 Mei 2021, 11:59

1 menjawab

Jawaban Terbaik