M- インデックス (Spring for Apache Kafka API)

A B C D E F G H I J K L M N O P R S T U V W Z
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 直列化された形式

M

manageNonBlockingFatalExceptions(List<Class<? extends Throwable>>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport: 非ブロック再試行の致命的な例外を管理するには、このメソッドをオーバーライドします。
MANUAL - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode: リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; 前のポーリングによって返されたすべてのレコードがリスナーによって処理されると、ack がキューに入れられ、オフセットがコミットされます。
MANUAL_IMMEDIATE - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode: リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; Acknowledgment が呼び出し元のコンシューマースレッドで確認応答された場合、コミットはすぐに実行されます。それ以外の場合は、前のポーリングによって返されたすべてのレコードがリスナーによって処理されたときに、ack がキューに入れられ、オフセットがコミットされます。呼び出し元のスレッドで確認する場合としない場合がある場合、結果は不確定になります。
ManualAckListenerErrorHandler - Interface in org.springframework.kafka.listener: 手動 ack をサポートする KafkaListenerErrorHandler。
MappingJacksonParameterizedConverter - org.springframework.kafka.support.converter のクラス: パラメーター化された (ジェネリクス) 型を処理できる MappingJackson2MessageConverter のサブクラス。
MappingJacksonParameterizedConverter() - クラス org.springframework.kafka.support.converter. MappingJacksonParameterizedConverter のコンストラクター: UTF-8 文字セットで application/json MIME 型をサポートする MappingJacksonParameterizedConverter を構築します。
MappingJacksonParameterizedConverter(MimeType...) - クラス org.springframework.kafka.support.converter. MappingJacksonParameterizedConverter のコンストラクター: 1 つ以上のカスタム MIME 型をサポートする MappingJacksonParameterizedConverter を構築します。
matches(Object, Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordKeyMatcher
matches(Object, Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordPartitionMatcher
matches(Object, Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordTimestampMatcher
matches(Object, Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordValueMatcher
matches(String) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper
matches(String, Object) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper
matches(ConsumerRecord<?, ?>) - クラス org.springframework.kafka.test.assertj のメソッド。KafkaConditions.ConsumerRecordPartitionCondition
matches(ConsumerRecord<?, ?>) - クラス org.springframework.kafka.test.assertj のメソッド。KafkaConditions.ConsumerRecordTimestampCondition
matches(ConsumerRecord<?, V>) - クラス org.springframework.kafka.test.assertj のメソッド。KafkaConditions.ConsumerRecordValueCondition
matches(ConsumerRecord<K, ?>) - クラス org.springframework.kafka.test.assertj のメソッド。KafkaConditions.ConsumerRecordKeyCondition
matches(ConsumerRecord<K, V>) - クラス org.springframework.kafka.test.assertj のメソッド。KafkaConditions.ConsumerRecordKeyValueCondition
matchesForInbound(String) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper: 受信マッパーとして構成されている場合、受信マッピングのヘッダー名を照合します。
matchHandlerMethod(Class<?>, InvocableHandlerMethod) - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler
matchHeader(String) - インターフェース org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper.HeaderMatcher: ヘッダーが一致する場合は true を返します。
matchHeader(String) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher
matchHeader(String) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher
maxAttempts(int) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder: 配信の最大試行回数 (初回を含む) を構成します。
maybeAddTo(String) - Method in class org.springframework.kafka.support.Suffixer
maybeAddTo(Collection<String>) - Method in class org.springframework.kafka.support.Suffixer
MessageConverter - Interface in org.springframework.kafka.support.converter: メッセージコンバーターのトップレベルのインターフェース。
MessageListener< K , V > - Interface in org.springframework.kafka.listener: 個々の受信 Kafka メッセージを処理するためのリスナー。
MessageListenerContainer - Interface in org.springframework.kafka.listener: メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。
messageReturnType() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult: messageReturnType レコードコンポーネントの値を返します。
MESSAGING_CLIENT_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags: メッセージングクライアント ID。
MESSAGING_CONSUMER_GROUP - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags: コンシューマーグループへのメッセージ送信。
MESSAGING_CONSUMER_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags: メッセージングコンシューマー ID (コンシューマーグループとクライアント ID)。
MESSAGING_DESTINATION_KIND - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags: メッセージングの宛先の種類。
MESSAGING_DESTINATION_NAME - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags: メッセージングの宛先名。
MESSAGING_OFFSET - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags: メッセージングメッセージのオフセット。
MESSAGING_OPERATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags: メッセージング操作。
MESSAGING_OPERATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags: メッセージング操作。
MESSAGING_PARTITION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerHighCardinalityTags: メッセージングパーティション。
MESSAGING_SOURCE_KIND - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags: メッセージングソースの種類。
MESSAGING_SOURCE_NAME - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags: メッセージングソース名。
MESSAGING_SYSTEM - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags: メッセージングシステム。
MESSAGING_SYSTEM - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags: メッセージングシステム。
MessagingFunction - Interface in org.springframework.kafka.streams.messaging: spring-messaging Message を受け取り、Message を返す関数。
MessagingMessageConverter - org.springframework.kafka.support.converter のクラス: 個々のメッセージを受信するメッセージリスナーのメッセージング MessageConverter 実装。
MessagingMessageConverter() - クラス org.springframework.kafka.support.converter. MessagingMessageConverter のコンストラクター: KafkaHeaders.PARTITION を使用してターゲットパーティションを決定するインスタンスを構築します。
MessagingMessageConverter(Function<Message<?>, Integer>) - クラス org.springframework.kafka.support.converter. MessagingMessageConverter のコンストラクター: 提供されたパーティションプロバイダー関数を使用するインスタンスを構築します。
MessagingMessageListenerAdapter< K , V > - Class in org.springframework.kafka.listener.adapter: Message のペイロードを抽出するために必要なインフラストラクチャを提供する抽象 MessageListener アダプター。
MessagingMessageListenerAdapter(Object, Method) - クラス org.springframework.kafka.listener.adapter. MessagingMessageListenerAdapter のコンストラクター: 提供された Bean とメソッドでインスタンスを作成します。
MessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - クラス org.springframework.kafka.listener.adapter. MessagingMessageListenerAdapter のコンストラクター: 提供された Bean メソッドと kafka リスナーエラーハンドラーを使用してインスタンスを作成します。
MessagingMessageListenerAdapter.ReplyExpressionRoot - org.springframework.kafka.listener.adapter の記録クラス: 応答式評価のルートオブジェクト。
MessagingProcessor<Kin,Vin,Kout,Vout> - Class in org.springframework.kafka.streams.messaging: spring-messaging Message との間で変換する MessagingFunction を呼び出す Transformer 実装。
MessagingProcessor(MessagingFunction, MessagingMessageConverter) - クラス org.springframework.kafka.streams.messaging. MessagingProcessor のコンストラクター: 提供された関数とコンバーターを使用してインスタンスを構築します。
MethodKafkaListenerEndpoint< K , V > - Class in org.springframework.kafka.config: このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供する KafkaListenerEndpoint。
MethodKafkaListenerEndpoint() - クラス org.springframework.kafka.config. MethodKafkaListenerEndpoint のコンストラクター
metrics() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer
metrics() - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations: Producer.metrics() を参照してください。
metrics() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
metrics() - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate
metrics() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
metrics() - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer
metrics() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer: client-id によってグループ化された、このコンテナーのコンシューマーによって保持されるメトリクスを返します。
metricsFromConsumer() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate
metricsFromProducer() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaProducerTemplate
MICROMETER_PRESENT - Static variable in class org.springframework.kafka.support.KafkaUtils: micrometer がクラスパス上にある場合は True。
MicrometerConsumerListener< K , V > - Class in org.springframework.kafka.core: KafkaClientMetrics を管理するコンシューマーファクトリリスナー。
MicrometerConsumerListener(MeterRegistry) - クラス org.springframework.kafka.core. MicrometerConsumerListener のコンストラクター: 提供されたレジストリを使用してインスタンスを構築します。
MicrometerConsumerListener(MeterRegistry, List<Tag>) - クラス org.springframework.kafka.core. MicrometerConsumerListener のコンストラクター: 提供されたレジストリとタグを使用してインスタンスを構築します。
MicrometerHolder - Class in org.springframework.kafka.support.micrometer: クラスパスで使用可能な場合の micrometer タイマーのラッパー。
MicrometerHolder(ApplicationContext, String, String, String, Function<Object, Map<String, String>>) - Constructor for class org.springframework.kafka.support.micrometer.MicrometerHolder: 提供されたプロパティでインスタンスを作成します。
MicrometerProducerListener< K , V > - Class in org.springframework.kafka.core: KafkaClientMetrics を管理するプロデューサーファクトリリスナー。
MicrometerProducerListener(MeterRegistry) - クラス org.springframework.kafka.core. MicrometerProducerListener のコンストラクター: 提供されたレジストリを使用してインスタンスを構築します。
MicrometerProducerListener(MeterRegistry, List<Tag>) - クラス org.springframework.kafka.core. MicrometerProducerListener のコンストラクター: 提供されたレジストリとタグを使用してインスタンスを構築します。
MockConsumerFactory< K , V > - Class in org.springframework.kafka.mock: テストでの MockConsumer の使用をサポートします。
MockConsumerFactory(Supplier<MockConsumer<K, V>>) - クラス org.springframework.kafka.mock. MockConsumerFactory のコンストラクター: 提供されたコンシューマープロバイダを使用してインスタンスを作成します。
MockProducerFactory< K , V > - Class in org.springframework.kafka.mock: テストでの MockProducer の使用をサポートします。
MockProducerFactory(BiFunction<Boolean, String, MockProducer<K, V>>, String) - クラス org.springframework.kafka.mock. MockProducerFactory のコンストラクター: 提供されたプロデューサープロバイダー BiFunctionSE を使用して、トランザクションをサポートするインスタンスを作成します。
MockProducerFactory(Supplier<MockProducer<K, V>>) - クラス org.springframework.kafka.mock. MockProducerFactory のコンストラクター: トランザクションプロデューサーをサポートしないインスタンスを作成します。
MultiMethodKafkaListenerEndpoint< K , V > - Class in org.springframework.kafka.config: KafkaHandler に基づくいくつかの POJO メソッドの MethodKafkaListenerEndpoint 拡張。
MultiMethodKafkaListenerEndpoint(List<Method>, Method, Object) - クラス org.springframework.kafka.config. MultiMethodKafkaListenerEndpoint のコンストラクター: 提供されたメソッド、デフォルトメソッド、Bean のインスタンスを構築します。
MULTIPLE_TOPICS - Enum constant in enum class org.springframework.kafka.retrytopic.SameIntervalTopicReuseStrategy: 再試行ごとに 1 つの個別のトピックを使用します。

A B C D E F G H I J K L M N O P R S T U V W Z
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 直列化された形式