クラスの使用
org.springframework.kafka.support.TopicPartitionOffset
TopicPartitionOffset を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
kafka 構成のパッケージ
kafka コアコンポーネントのパッケージ
kafka リスナーのためのパッケージ
org.springframework.kafka.annotation 内の TopicPartitionOffset 使用
型 TopicPartitionOffset のパラメーターを持つ org.springframework.kafka.annotation のメソッド修飾子と型メソッド説明protected voidKafkaListenerAnnotationBeanPostProcessor.processListener(MethodKafkaListenerEndpoint<?, ?> endpoint, KafkaListener kafkaListener, ObjectSE bean, StringSE beanName, StringSE[] topics, TopicPartitionOffset[] tps) org.springframework.kafka.config 内の TopicPartitionOffset 使用
修飾子と型メソッド説明TopicPartitionOffset @Nullable[]AbstractKafkaListenerEndpoint.getTopicPartitionsToAssign()このエンドポイントの topicPartitions を返します。TopicPartitionOffset @Nullable[]KafkaListenerEndpoint.getTopicPartitionsToAssign()このエンドポイントの topicPartitions を返します。型 TopicPartitionOffset のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明AbstractKafkaListenerContainerFactory.createContainer(TopicPartitionOffset... topicsAndPartitions) KafkaListenerContainerFactory.createContainer(TopicPartitionOffset... topicPartitions) リスナーなしでコンテナーを作成して構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。ShareKafkaListenerContainerFactory.createContainer(TopicPartitionOffset... topicPartitions) voidAbstractKafkaListenerEndpoint.setTopicPartitions(TopicPartitionOffset... topicPartitions) 使用する topicPartitions を設定します。org.springframework.kafka.core 内の TopicPartitionOffset 使用
型 TopicPartitionOffset の型引数を持つ org.springframework.kafka.core のメソッドパラメーター修飾子と型メソッド説明KafkaOperations.receive(CollectionSE<TopicPartitionOffset> requested) デフォルトのポーリングタイムアウト（5 秒）で複数のレコードを受信します。KafkaOperations.receive(CollectionSE<TopicPartitionOffset> requested, DurationSE pollTimeout) 複数のレコードを受信します。KafkaTemplate.receive(CollectionSE<TopicPartitionOffset> requested, DurationSE pollTimeout) org.springframework.kafka.listener 内の TopicPartitionOffset 使用
修飾子と型メソッド説明TopicPartitionOffset @Nullable[]ConsumerProperties.getTopicPartitions()構成済みのTopicPartitionOffsetを返します。型 TopicPartitionOffset のパラメーターを持つ org.springframework.kafka.listener のメソッド修飾子と型メソッド説明default intCommonErrorHandler.deliveryAttempt(TopicPartitionOffset topicPartitionOffset) intCommonMixedErrorHandler.deliveryAttempt(TopicPartitionOffset topicPartitionOffset) intDeliveryAttemptAware.deliveryAttempt(TopicPartitionOffset topicPartitionOffset) トピック / パーティション / オフセットの次の配信試行を返します。intFailedRecordProcessor.deliveryAttempt(TopicPartitionOffset topicPartitionOffset) 型 TopicPartitionOffset のパラメーターを持つ org.springframework.kafka.listener のコンストラクター修飾子コンストラクター説明ConsumerProperties(TopicPartitionOffset... topicPartitions) 提供されたトピックパーティションを自分自身に割り当てるコンテナーのプロパティを作成します。ContainerProperties(TopicPartitionOffset... topicPartitions) 提供されたトピックパーティションを自分自身に割り当てるコンテナーのプロパティを作成します。