public class InitialOffsetsFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>OffsetManager を初期化するためのマップを作成します。| 修飾子と型 | フィールドと説明 |
|---|---|
static java.util.regex.Pattern | VALIDATION_PATTERN |
| コンストラクターと説明 |
|---|
InitialOffsetsFactoryBean(java.lang.String topics, java.lang.String initialOffsetList) |
| 修飾子と型 | メソッドと説明 |
|---|---|
java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long> | getObject() |
java.lang.Class<?> | getObjectType() |
boolean | isSingleton() |
public InitialOffsetsFactoryBean(java.lang.String topics,
java.lang.String initialOffsetList)public java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long> getObject()
throws java.lang.Exceptionorg.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>> 内の getObject java.lang.Exceptionpublic java.lang.Class<?> getObjectType()
org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>> 内の getObjectType public boolean isSingleton()
org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>> 内の isSingleton