本文整理了Java中org.apache.kafka.clients.producer.Producer.abortTransaction()方法的一些代码示例，展示了Producer.abortTransaction()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Producer.abortTransaction()方法的具体详情如下：
包路径：org.apache.kafka.clients.producer.Producer
类名称：Producer
方法名：abortTransaction

Producer.abortTransaction介绍

[英]See KafkaProducer#abortTransaction()
[中]参见卡夫卡制作人#abortTransaction（）

代码示例

代码示例来源：origin: apache/nifi

void rollback() {
  if (!useTransactions || !activeTransaction) {
    return;
  }
  producer.abortTransaction();
  activeTransaction = false;
}

代码示例来源：origin: apache/nifi

void rollback() {
  if (!useTransactions || !activeTransaction) {
    return;
  }
  producer.abortTransaction();
  activeTransaction = false;
}

代码示例来源：origin: apache/nifi

void rollback() {
  if (!useTransactions || !activeTransaction) {
    return;
  }
  producer.abortTransaction();
  activeTransaction = false;
}

代码示例来源：origin: openzipkin/brave

@Override public void abortTransaction() {
 delegate.abortTransaction();
}

代码示例来源：origin: alibaba/canal

logger.error(e.getMessage(), e);
if (kafkaProperties.getTransaction()) {
  producerTmp.abortTransaction();

代码示例来源：origin: spring-projects/spring-kafka

public void rollback() {
  this.producer.abortTransaction();
}

代码示例来源：origin: spring-projects/spring-kafka

@Override
public void abortTransaction() throws ProducerFencedException {
  if (logger.isDebugEnabled()) {
    logger.debug("abortTransaction: " + this);
  }
  try {
    this.delegate.abortTransaction();
  }
  catch (RuntimeException e) {
    if (logger.isErrorEnabled()) {
      logger.error("Abort failed: " + this, e);
    }
    this.txFailed = true;
    throw e;
  }
}

代码示例来源：origin: spring-projects/spring-kafka

@SuppressWarnings("unchecked")
@Test
public void discardRemainingRecordsFromPollAndSeek() throws Exception {
  assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
  assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();
  this.registry.stop();
  assertThat(this.config.closeLatch.await(10, TimeUnit.SECONDS)).isTrue();
  InOrder inOrder = inOrder(this.consumer, this.producer);
  inOrder.verify(this.consumer).subscribe(any(Collection.class), any(ConsumerRebalanceListener.class));
  inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  inOrder.verify(this.producer).beginTransaction();
  inOrder.verify(this.consumer).seek(new TopicPartition("foo", 0), 0L);
  inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 0L);
  inOrder.verify(this.consumer).seek(new TopicPartition("foo", 2), 0L);
  inOrder.verify(this.producer).abortTransaction();
  inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  inOrder.verify(this.producer).beginTransaction();
  Map<TopicPartition, OffsetAndMetadata> offsets = new LinkedHashMap<>();
  offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(2L));
  offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(2L));
  offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(2L));
  inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  inOrder.verify(this.producer).commitTransaction();
  assertThat(this.config.ehException).isInstanceOf(ListenerExecutionFailedException.class);
  assertThat(((ListenerExecutionFailedException) this.config.ehException).getGroupId()).isEqualTo(CONTAINER_ID);
}

代码示例来源：origin: spring-projects/spring-kafka

producer.abortTransaction();
throw e;

代码示例来源：origin: spring-projects/spring-kafka

inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 1L);
inOrder.verify(this.consumer).seek(new TopicPartition("foo", 2), 0L);
inOrder.verify(this.producer).abortTransaction();
inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
offsets.clear();

代码示例来源：origin: spring-projects/spring-kafka

inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 1L);
inOrder.verify(this.consumer).seek(new TopicPartition("foo", 2), 0L);
inOrder.verify(this.producer).abortTransaction();
inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
offsets.clear();

代码示例来源：origin: org.axonframework.extensions.kafka/axon-kafka

@Override
public void abortTransaction() throws ProducerFencedException {
  this.delegate.abortTransaction();
}

代码示例来源：origin: org.apache.nifi/nifi-kafka-1-0-processors

void rollback() {
  if (!useTransactions || !activeTransaction) {
    return;
  }
  producer.abortTransaction();
  activeTransaction = false;
}

代码示例来源：origin: opentracing-contrib/java-kafka-client

@Override
public void abortTransaction() throws ProducerFencedException {
 producer.abortTransaction();
}

代码示例来源：origin: org.apache.nifi/nifi-kafka-2-0-processors

void rollback() {
  if (!useTransactions || !activeTransaction) {
    return;
  }
  producer.abortTransaction();
  activeTransaction = false;
}

代码示例来源：origin: org.axonframework/axon-kafka

@Override
public void abortTransaction() throws ProducerFencedException {
  this.delegate.abortTransaction();
}

代码示例来源：origin: org.axonframework/axon-kafka

private void tryRollback(Producer<?, ?> producer) {
    try {
      producer.abortTransaction();
    } catch (Exception e) {
      logger.warn("Unable to abort transaction", e);
      //not re-throwing exception, its too late
    }
  }
}

代码示例来源：origin: spring-projects/spring-kafka

inOrder.verify(producer, never()).sendOffsetsToTransaction(anyMap(), anyString());
inOrder.verify(producer, never()).commitTransaction();
inOrder.verify(producer).abortTransaction();
inOrder.verify(producer).close();
verify(consumer).seek(topicPartition0, 0);

代码示例来源：origin: spring-projects/spring-kafka

inOrder.verify(producer, never()).sendOffsetsToTransaction(anyMap(), anyString());
inOrder.verify(producer, never()).commitTransaction();
inOrder.verify(producer).abortTransaction();
inOrder.verify(producer).close();
verify(consumer).seek(topicPartition0, 0);

代码示例来源：origin: org.axonframework.extensions.kafka/axon-kafka

private void tryRollback(Producer<?, ?> producer) {
  try {
    producer.abortTransaction();
  } catch (Exception e) {
    logger.warn("Unable to abort transaction", e);
    //not re-throwing exception, its too late
  }
}