ApsaraMQ for RocketMQ:Metode dan parameter

Antarmuka PullConsumer

public interface PullConsumer extends Admin {

    /**
     * Mengembalikan semua partisi untuk topik yang ditentukan.
     * Panggil metode ini hanya setelah konsumen pull telah dimulai.
     */
    Set<TopicPartition> topicPartitions(String topic);

    /**
     * Menetapkan partisi secara manual ke konsumen ini. Penyeimbangan ulang otomatis
     * tidak dilakukan -- pastikan semua partisi tercakup oleh
     * seluruh konsumen Anda. Memanggil metode ini lagi akan menggantikan
     * penetapan sebelumnya sepenuhnya.
     */
    void assign(Collection<TopicPartition> topicPartitions);

    /**
     * Melakukan polling untuk pesan. Mengembalikan hingga maxBatchMessageCount pesan,
     * dengan pemblokiran maksimal selama timeout yang ditentukan (dalam milidetik).
     */
    List<Message> poll(long timeout);

    /**
     * Mengatur ulang offset konsumen suatu partisi ke posisi tertentu.
     * Offset harus berada di antara offset minimum dan maksimum partisi tersebut.
     * Panggil metode ini hanya setelah konsumen telah dimulai dan
     * telah ditetapkan ke partisi target.
     */
    void seek(TopicPartition topicPartition, long offset);

    /**
     * Mengatur ulang offset konsumen suatu partisi ke pesan paling awal
     * yang tersedia. Memerlukan konsumen yang telah dimulai dan ditetapkan ke
     * partisi target.
     */
    void seekToBeginning(TopicPartition topicPartition);

    /**
     * Mengatur ulang offset konsumen suatu partisi ke pesan terbaru.
     * Memerlukan konsumen yang telah dimulai dan ditetapkan ke
     * partisi target.
     */
    void seekToEnd(TopicPartition topicPartition);

    /**
     * Menangguhkan konsumsi pesan pada partisi yang ditentukan.
     */
    void pause(Collection<TopicPartition> topicPartitions);

    /**
     * Melanjutkan konsumsi pesan pada partisi yang sebelumnya ditangguhkan.
     */
    void resume(Collection<TopicPartition> topicPartitions);

    /**
     * Mengembalikan offset pesan pertama yang disimpan pada atau setelah
     * timestamp yang diberikan dalam partisi tertentu. Timestamp mengacu pada
     * saat broker menyimpan pesan, bukan saat pesan dikirim.
     */
    Long offsetForTimestamp(TopicPartition topicPartition, Long timestamp);

    /**
     * Mengembalikan offset konsumen terbaru untuk partisi yang ditentukan.
     */
    Long committed(TopicPartition topicPartition);

    /**
     * Melakukan commit offset konsumen saat ini secara sinkron. Offset terlebih dahulu
     * disinkronkan ke client lokal, lalu ditulis ke broker secara asinkron.
     */
    void commitSync();

    /**
     * Antarmuka pendengar untuk event perubahan partisi.
     */
    interface TopicPartitionChangeListener {
        /**
         * Dipanggil ketika partisi suatu topik berubah -- misalnya,
         * setelah penskalaan broker menyesuaikan jumlah partisi.
         */
        void onChanged(Set<TopicPartition> topicPartitions);
    }

    /**
     * Mendaftarkan pendengar yang dipicu ketika jumlah partisi suatu
     * topik berubah (misalnya, karena penskalaan broker). Secara bawaan,
     * penundaan maksimum callback adalah 5 detik.
     */
    void registerTopicPartitionChangedListener(String topic,
            TopicPartitionChangeListener callback);
}