THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
On the public Producer API, we shall also document the new exceptions to let user catch it, do the transaction abortion and restart a new transaction for both TransactionTimedOutException and InvalidProducerEpochException. The only exception is the "abortTransaction", which was supposed to be safe when being called inside the catch block for abortable exceptions.
| Code Block | ||||
|---|---|---|---|---|
| ||||
/** * @throws TransactionTimedOutException if the producer has encountered a previously aborted transaction on coordinator side. * Application should catch it and retry starting another transaction in this case. * @throws org.apache.kafka.common.errors.InvalidProducerEpochException if the producer has attempted to produce with an old epoch * to the partition leader. See the exception for more details */ public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId); /** * @throws TransactionTimedOutException if the producer has encountered a previously aborted transaction on coordinator side. * Application should catch it and retry starting another transaction in this case. * @throws org.apache.kafka.common.errors.InvalidProducerEpochException if the producer has attempted to produce with an old epoch * to the partition leader. See the exception for more details */ public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata); /** * @throws TransactionTimedOutException if the producer has encountered a previously aborted transaction on coordinator side. * Application should catch it and retry starting another transaction in this case. * @throws org.apache.kafka.common.errors.InvalidProducerEpochException if the producer has attempted to produce with an old epoch to the partition leader. * Applicationto shouldthe catchpartition itleader. andSee retrythe startingexception anotherfor transaction in this case.more details */ public void commitTransaction(); /** * (In callback:) * @throws InvalidProducerEpochException if the producer has attempted to produce with an old epoch to the partition leader. * Application should catch it and retry starting another transaction in this case. */ public Future<RecordMetadata> send(ProducerRecord<K, V> record, Callback callback); |
...