@@ -185,21 +185,23 @@ public interface KafkaOperations<K, V> {
185
185
void flush ();
186
186
187
187
/**
188
- * When running in a transaction (usually synchronized with some other transaction),
189
- * send the consumer offset(s) to the transaction. The group id is obtained from
190
- * {@link ProducerFactoryUtils#getConsumerGroupId()}. It is not necessary to call
191
- * this method if the operations are invoked on a listener container thread since the
192
- * container will take care of sending the offsets to the transaction.
188
+ * When running in a transaction, send the consumer offset(s) to the transaction. The
189
+ * group id is obtained from {@link ProducerFactoryUtils#getConsumerGroupId()}. It is
190
+ * not necessary to call this method if the operations are invoked on a listener
191
+ * container thread (and the listener container is configured with a
192
+ * {@link org.springframework.kafka.transaction.KafkaAwareTransactionManager}) since
193
+ * the container will take care of sending the offsets to the transaction.
193
194
* @param offsets The offsets.
194
195
* @since 1.3
195
196
*/
196
197
void sendOffsetsToTransaction (Map <TopicPartition , OffsetAndMetadata > offsets );
197
198
198
199
/**
199
- * When running in a transaction (usually synchronized with some other transaction),
200
- * send the consumer offset(s) to the transaction. It is not necessary to call this
201
- * method if the operations are invoked on a listener container thread since the
202
- * container will take care of sending the offsets to the transaction.
200
+ * When running in a transaction, send the consumer offset(s) to the transaction. It
201
+ * is not necessary to call this method if the operations are invoked on a listener
202
+ * container thread (and the listener container is configured with a
203
+ * {@link org.springframework.kafka.transaction.KafkaAwareTransactionManager}) since
204
+ * the container will take care of sending the offsets to the transaction.
203
205
* @param offsets The offsets.
204
206
* @param consumerGroupId the consumer's group.id.
205
207
* @since 1.3
0 commit comments