クラス DefaultKafkaProducerFactory<K,V>

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setBeanName

  public void setBeanName(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setKeySerializer

  public void setKeySerializer(@Nullable org.apache.kafka.common.serialization.Serializer<K> keySerializer)

  キーシリアライザーを設定します。configureSerializers が false でない限り、シリアライザーはプロデューサー構成を使用して構成されます。

  パラメーター:

  keySerializer - キーシリアライザー。

  関連事項:

  • setConfigureSerializers(boolean)

• setValueSerializer

  public void setValueSerializer(@Nullable org.apache.kafka.common.serialization.Serializer<V> valueSerializer)

  値シリアライザーを設定します。configureSerializers が false でない限り、シリアライザーはプロデューサー構成を使用して構成されます。

  パラメーター:

  valueSerializer - 値シリアライザー。

  関連事項:

  • setConfigureSerializers(boolean)

• setKeySerializerSupplier

  public void setKeySerializerSupplier(@Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Serializer<K>> keySerializerSupplier)

  キーシリアライザーのインスタンスを提供するようにサプライヤーを設定します。configureSerializers が false でない限り、シリアライザーはプロデューサー構成を使用して構成されます。

  パラメーター:

  keySerializerSupplier - サプライヤー。

  導入:

  2.8

  関連事項:

  • setConfigureSerializers(boolean)

• setValueSerializerSupplier

  public void setValueSerializerSupplier(@Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Serializer<V>> valueSerializerSupplier)

  値シリアライザーのインスタンスを提供するようにサプライヤーを設定します。

  パラメーター:

  valueSerializerSupplier - サプライヤー。configureSerializers が false でない限り、シリアライザーはプロデューサー構成を使用して構成されます。

  導入:

  2.8

  関連事項:

  • setConfigureSerializers(boolean)

• setTransactionIdSuffixStrategy

  public void setTransactionIdSuffixStrategy(TransactionIdSuffixStrategy transactionIdSuffixStrategy)

  トランザクションサフィックス戦略を設定します。

  パラメーター:

  transactionIdSuffixStrategy - 戦略。

  導入:

  3.2

• isConfigureSerializers

  public boolean isConfigureSerializers()

  true（デフォルト）の場合、プログラムで提供されるシリアライザー（コンストラクターまたは setter を介して）は、プロデューサー構成を使用して構成されます。シリアライザーがすでに完全に構成されている場合は、false に設定します。

  戻り値:

  構成する場合は true。

  導入:

  2.8.7

  関連事項:

  • setKeySerializer(Serializer)
  • setKeySerializerSupplier(Supplier)
  • setValueSerializer(Serializer)
  • setValueSerializerSupplier(Supplier)

• setConfigureSerializers

  public void setConfigureSerializers(boolean configureSerializers)

  false（デフォルトは true）に設定して、プログラムで提供されたシリアライザー（コンストラクターまたは setter を介して）がプロデューサー構成を使用して構成されないようにします。シリアライザーがすでに完全に構成されている場合。

  パラメーター:

  configureSerializers - 構成しない場合は false。

  導入:

  2.8.7

  関連事項:

  • setKeySerializer(Serializer)
  • setKeySerializerSupplier(Supplier)
  • setValueSerializer(Serializer)
  • setValueSerializerSupplier(Supplier)

• setPhysicalCloseTimeout

  public void setPhysicalCloseTimeout(int physicalCloseTimeout)

  プロデューサー自体を閉じるのではなく、ファクトリを介してプロデューサーを物理的に閉じるときに待機する時間（reset()、#closeProducerFor(String)、closeThreadBoundProducer() が呼び出されたとき）。秒単位で指定。デフォルトの ProducerFactory.DEFAULT_PHYSICAL_CLOSE_TIMEOUT。

  パラメーター:

  physicalCloseTimeout - 秒単位のタイムアウト。

  導入:

  1.0.7

• getPhysicalCloseTimeout

  public DurationSE getPhysicalCloseTimeout()

  物理的なクローズタイムアウトを取得します。

  次で指定:

  インターフェース ProducerFactory<K,V> の getPhysicalCloseTimeout 

  戻り値:

  タイムアウト。

  導入:

  2.5

• setTransactionIdPrefix

  public final void setTransactionIdPrefix(StringSE transactionIdPrefix)

  ProducerConfig.TRANSACTIONAL_ID_CONFIG 構成のプレフィックスを設定します。デフォルトでは、構成の ProducerConfig.TRANSACTIONAL_ID_CONFIG 値がターゲットプロデューサー構成のプレフィックスとして使用されます。

  パラメーター:

  transactionIdPrefix - プレフィックス。

  導入:

  1.3

• getTransactionIdPrefix

  public @Nullable StringSE getTransactionIdPrefix()

  インターフェースからコピーされた説明: ProducerFactory

  トランザクション ID プレフィックスを返します。

  次で指定:

  インターフェース ProducerFactory<K,V> の getTransactionIdPrefix 

  戻り値:

  プレフィックスまたは設定されていない場合は null。

• setProducerPerThread

  public void setProducerPerThread(boolean producerPerThread)

  すべてのクライアントで共有されるシングルトンではなく、スレッドごとにプロデューサーを作成するには、true に設定します。クライアント は、closeThreadBoundProducer() を呼び出して、プロデューサーが不要になったときに物理的に閉じる必要があります。これらのプロデューサーは、destroy() または reset() によって閉鎖されることはありません。

  パラメーター:

  producerPerThread - スレッドごとのプロデューサーに当てはまります。

  導入:

  2.3

  関連事項:

  • closeThreadBoundProducer()

• isProducerPerThread

  public boolean isProducerPerThread()

  インターフェースからコピーされた説明: ProducerFactory

  スレッドごとにプロデューサーが存在する場合は true を返します。

  次で指定:

  インターフェース ProducerFactory<K,V> の isProducerPerThread 

  戻り値:

  スレッドごとのプロデューサー。

• getKeySerializer

  public @Nullable org.apache.kafka.common.serialization.Serializer<K> getKeySerializer()

  インターフェースからコピーされた説明: ProducerFactory

  構成されたキーシリアライザーを返します（プロパティでクラス名の代わりにオブジェクトとして提供されている場合）。

  次で指定:

  インターフェース ProducerFactory<K,V> の getKeySerializer 

  戻り値:

  シリアライザー。

• getValueSerializer

  public @Nullable org.apache.kafka.common.serialization.Serializer<V> getValueSerializer()

  インターフェースからコピーされた説明: ProducerFactory

  構成された値シリアライザーを返します（プロパティでクラス名の代わりにオブジェクトとして提供されている場合）。

  次で指定:

  インターフェース ProducerFactory<K,V> の getValueSerializer 

  戻り値:

  シリアライザー。

• getKeySerializerSupplier

  public @Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Serializer<K>> getKeySerializerSupplier()

  インターフェースからコピーされた説明: ProducerFactory

  キーシリアライザーのサプライヤーを return してください。同様のファクトリを作成するためのクローン作成に役立ちます。

  次で指定:

  インターフェース ProducerFactory<K,V> の getKeySerializerSupplier 

  戻り値:

  サプライヤー。

• getValueSerializerSupplier

  public @Nullable SupplierSE<@Nullable org.apache.kafka.common.serialization.Serializer<V>> getValueSerializerSupplier()

  インターフェースからコピーされた説明: ProducerFactory

  バリューシリアライザーのサプライヤーを return してください。同様のファクトリを作成するためのクローン作成に役立ちます。

  次で指定:

  インターフェース ProducerFactory<K,V> の getValueSerializerSupplier 

  戻り値:

  サプライヤー。

• getConfigurationProperties

  public MapSE<StringSE,ObjectSE> getConfigurationProperties()

  このファクトリの構成マップへの変更不可能な参照を返します。類似のファクトリを作るためのクローン作成に便利です。

  次で指定:

  インターフェース ProducerFactory<K,V> の getConfigurationProperties 

  戻り値:

  構成。

  導入:

  1.3

• getListeners

  public ListSE<ProducerFactory.Listener<K,V>> getListeners()

  リスナーの現在のリストを取得します。

  次で指定:

  インターフェース ProducerFactory<K,V> の getListeners 

  戻り値:

  リスナー。

  導入:

  2.5

• getPostProcessors

  public ListSE<ProducerPostProcessor<K,V>> getPostProcessors()

  インターフェースからコピーされた説明: ProducerFactory

  ポストプロセッサーの現在のリストを取得します。

  次で指定:

  インターフェース ProducerFactory<K,V> の getPostProcessors 

  戻り値:

  ポストプロセッサー。

• setMaxAge

  public void setMaxAge(DurationSE maxAge)

  プロデューサーの最大年齢を設定します。トランザクションを使用するときに便利で、非アクティブのためにブローカーが transactional.id を期限切れにする可能性があります。

  パラメーター:

  maxAge - 設定する maxAge

  導入:

  2.5.8

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• getPhase

  public int getPhase()

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

• copyWithConfigurationOverride

  public ProducerFactory<K,V> copyWithConfigurationOverride(@Nullable MapSE<StringSE,ObjectSE> overrideProperties)

  インスタンスのプロパティと指定されたプロパティをコピーして、新しいプロデューサーファクトリを作成します。

  DefaultKafkaProducerFactory がそれ自体のコピーを作成する場合、トランザクション ID プレフィックスがプロパティからリカバリされます。ID 構成を変更する場合は、オーバーライド構成に新しい ProducerConfig.TRANSACTIONAL_ID_CONFIG キーを追加します。

  次で指定:

  インターフェース ProducerFactory<K,V> の copyWithConfigurationOverride 

  パラメーター:

  overrideProperties - 新しいファクトリに適用されるプロパティ

  戻り値:

  プロパティが適用された DefaultKafkaProducerFactory

  関連事項:

  • KafkaTemplate(ProducerFactory, java.util.Map)

• addListener

  public void addListener(ProducerFactory.Listener<K,V> listener)

  リスナーを追加します。

  次で指定:

  インターフェース ProducerFactory<K,V> の addListener 

  パラメーター:

  listener - リスナー。

  導入:

  2.5

• addListener

  public void addListener(int index, ProducerFactory.Listener<K,V> listener)

  特定のインデックスにリスナーを追加します。

  次で指定:

  インターフェース ProducerFactory<K,V> の addListener 

  パラメーター:

  index - インデックス (リストの位置)。

  listener - リスナー。

  導入:

  2.5

• removeListener

  public boolean removeListener(ProducerFactory.Listener<K,V> listener)

  リスナーを削除します。

  次で指定:

  インターフェース ProducerFactory<K,V> の removeListener 

  パラメーター:

  listener - リスナー。

  戻り値:

  削除された場合は true。

  導入:

  2.5

• addPostProcessor

  public void addPostProcessor(ProducerPostProcessor<K,V> postProcessor)

  インターフェースからコピーされた説明: ProducerFactory

  ポストプロセッサーを追加します。

  次で指定:

  インターフェース ProducerFactory<K,V> の addPostProcessor 

  パラメーター:

  postProcessor - ポストプロセッサー。

• removePostProcessor

  public boolean removePostProcessor(ProducerPostProcessor<K,V> postProcessor)

  インターフェースからコピーされた説明: ProducerFactory

  ポストプロセッサーを取り外します。

  次で指定:

  インターフェース ProducerFactory<K,V> の removePostProcessor 

  パラメーター:

  postProcessor - ポストプロセッサー。

  戻り値:

  削除された場合は true。

• updateConfigs

  public void updateConfigs(MapSE<StringSE,ObjectSE> updates)

  インターフェースからコピーされた説明: ProducerFactory

  プロデューサー構成マップを更新します。クレデンシャルローテーションなどの状況で役立ちます。

  次で指定:

  インターフェース ProducerFactory<K,V> の updateConfigs 

  パラメーター:

  updates - 更新する構成プロパティ。

• removeConfig

  public void removeConfig(StringSE configKey)

  インターフェースからコピーされた説明: ProducerFactory

  指定されたキーを構成マップから削除します。

  次で指定:

  インターフェース ProducerFactory<K,V> の removeConfig 

  パラメーター:

  configKey - 削除するキー。

• transactionCapable

  public boolean transactionCapable()

  インターフェースからコピーされた説明: ProducerFactory

  ファクトリがトランザクションをサポートしている場合は true を返します。

  次で指定:

  インターフェース ProducerFactory<K,V> の transactionCapable 

  戻り値:

  トランザクションの場合は true。

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• onApplicationEvent

  public void onApplicationEvent(ContextStoppedEvent event)

  次で指定:

  インターフェース ApplicationListener<K> の onApplicationEvent 

• reset

  public void reset()

  Producer (s) を閉じ、トランザクション Producer (s) のキャッシュをクリアします。

  次で指定:

  インターフェース ProducerFactory<K,V> の reset 

  導入:

  2.2

• createProducer

  public org.apache.kafka.clients.producer.Producer<K,V> createProducer()

  インターフェースからコピーされた説明: ProducerFactory

  ファクトリがそのように構成されている場合にトランザクションになるプロデューサーを作成します。

  次で指定:

  インターフェース ProducerFactory<K,V> の createProducer 

  戻り値:

  プロデューサー。

  関連事項:

  • ProducerFactory.transactionCapable()

• createProducer

  public org.apache.kafka.clients.producer.Producer<K,V> createProducer(@Nullable StringSE txIdPrefixArg)

  インターフェースからコピーされた説明: ProducerFactory

  オーバーライドされたトランザクション ID プレフィックスを使用してプロデューサーを作成します。

  次で指定:

  インターフェース ProducerFactory<K,V> の createProducer 

  パラメーター:

  txIdPrefixArg - トランザクション ID プレフィックス。

  戻り値:

  プロデューサー。

• createNonTransactionalProducer

  public org.apache.kafka.clients.producer.Producer<K,V> createNonTransactionalProducer()

  インターフェースからコピーされた説明: ProducerFactory

  非トランザクションプロデューサーを作成します。

  次で指定:

  インターフェース ProducerFactory<K,V> の createNonTransactionalProducer 

  戻り値:

  プロデューサー。

  関連事項:

  • ProducerFactory.transactionCapable()

• createKafkaProducer

  protected org.apache.kafka.clients.producer.Producer<K,V> createKafkaProducer()

  サブクラスは、DefaultKafkaProducerFactory.CloseSafeProducer にラップされる生のプロデューサーを返す必要があります。

  戻り値:

  プロデューサー。

• removeProducer

  protected final boolean removeProducer(DefaultKafkaProducerFactory.CloseSafeProducer<K,V> producerToRemove, DurationSE timeout)

  存在する場合は、単一の共有プロデューサーとスレッドバインドインスタンスを削除します。

  パラメーター:

  producerToRemove - プロデューサー。

  timeout - クローズタイムアウト。

  戻り値:

  プロデューサーが閉じられている場合は true。

  導入:

  2.2.13

• createTransactionalProducer

  protected org.apache.kafka.clients.producer.Producer<K,V> createTransactionalProducer()

  サブクラスは、getCache() からのプロデューサー、または DefaultKafkaProducerFactory.CloseSafeProducer にラップされた新しい生のプロデューサーを返す必要があります。

  戻り値:

  プロデューサー -null にすることはできません。

  導入:

  1.3

• createTransactionalProducer

  protected org.apache.kafka.clients.producer.Producer<K,V> createTransactionalProducer(@Nullable StringSE txIdPrefix)

• createRawProducer

  protected org.apache.kafka.clients.producer.Producer<K,V> createRawProducer(MapSE<StringSE,ObjectSE> rawConfigs)

• getCache

  protected @Nullable BlockingQueueSE<DefaultKafkaProducerFactory.CloseSafeProducer<K,V>> getCache()

• getCache

  protected @Nullable BlockingQueueSE<DefaultKafkaProducerFactory.CloseSafeProducer<K,V>> getCache(@Nullable StringSE txIdPrefix)

• closeThreadBoundProducer

  public void closeThreadBoundProducer()

  setProducerPerThread(boolean)（true）を使用する場合は、このメソッドを呼び出して、このスレッドのプロデューサーを閉じて解放します。スレッドにバインドされたプロデューサーは、destroy() または reset() メソッドによって閉じられません。

  次で指定:

  インターフェース ProducerFactory<K,V> の closeThreadBoundProducer 

  導入:

  2.3

  関連事項:

  • setProducerPerThread(boolean)

• getProducerConfigs

  protected MapSE<StringSE,ObjectSE> getProducerConfigs()

  プロデューサーの構成を返します。

  戻り値:

  プロデューサーの構成。

  導入:

  2.8.3

  関連事項:

  • createKafkaProducer()

• getTxProducerConfigs

  protected MapSE<StringSE,ObjectSE> getTxProducerConfigs(StringSE transactionId)

  トランザクションプロデューサーの構成を返します。

  パラメーター:

  transactionId - transactionId。

  戻り値:

  トランザクションプロデューサーの構成。

  導入:

  2.8.3

  関連事項:

  • doCreateTxProducer(String, String, BiPredicate)