org.apache.kafka.clients.producer.Producer.sendOffsetsToTransaction()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(194)

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

Producer.sendOffsetsToTransaction介绍

[英]See KafkaProducer#sendOffsetsToTransaction(Map,String)
[中]参见KafkaProducer#sendOffsetsToTransaction（地图，字符串）

代码示例

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

  1. @Override
  2.  public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets,
  3.    String consumerGroupId) {
  4.   delegate.sendOffsetsToTransaction(offsets, consumerGroupId);
  5.  }
  6. }

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId)
  3.     throws ProducerFencedException {
  4.   this.delegate.sendOffsetsToTransaction(offsets, consumerGroupId);
  5. }

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId) {
  3.   @SuppressWarnings("unchecked")
  4.   KafkaResourceHolder<K, V> resourceHolder = (KafkaResourceHolder<K, V>) TransactionSynchronizationManager
  5.       .getResource(this.producerFactory);
  6.   Assert.isTrue(resourceHolder != null, "No transaction in process");
  7.   if (resourceHolder.getProducer() != null) {
  8.     resourceHolder.getProducer().sendOffsetsToTransaction(offsets, consumerGroupId);
  9.   }
  10. }

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

  1. Map<TopicPartition, OffsetAndMetadata> offsets = new LinkedHashMap<>();
  2. offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(1L));
  3. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  4. inOrder.verify(this.producer).commitTransaction();
  5. offsets.clear();
  6. offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(2L));
  7. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  8. inOrder.verify(this.producer).commitTransaction();
  9. offsets.clear();
  10. offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(1L));
  11. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  12. inOrder.verify(this.producer).commitTransaction();
  13. inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 1L);
  14. offsets.clear();
  15. offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(2L));
  16. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  17. inOrder.verify(this.producer).commitTransaction();
  18. offsets.clear();
  19. offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(1L));
  20. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  21. inOrder.verify(this.producer).commitTransaction();
  22. offsets.clear();
  23. offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(2L));
  24. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  25. inOrder.verify(this.producer).commitTransaction();
  26. inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void discardRemainingRecordsFromPollAndSeek() throws Exception {
  4.   assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
  5.   assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();
  6.   this.registry.stop();
  7.   assertThat(this.config.closeLatch.await(10, TimeUnit.SECONDS)).isTrue();
  8.   InOrder inOrder = inOrder(this.consumer, this.producer);
  9.   inOrder.verify(this.consumer).subscribe(any(Collection.class), any(ConsumerRebalanceListener.class));
  10.   inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  11.   inOrder.verify(this.producer).beginTransaction();
  12.   inOrder.verify(this.consumer).seek(new TopicPartition("foo", 0), 0L);
  13.   inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 0L);
  14.   inOrder.verify(this.consumer).seek(new TopicPartition("foo", 2), 0L);
  15.   inOrder.verify(this.producer).abortTransaction();
  16.   inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  17.   inOrder.verify(this.producer).beginTransaction();
  18.   Map<TopicPartition, OffsetAndMetadata> offsets = new LinkedHashMap<>();
  19.   offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(2L));
  20.   offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(2L));
  21.   offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(2L));
  22.   inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  23.   inOrder.verify(this.producer).commitTransaction();
  24.   assertThat(this.config.ehException).isInstanceOf(ListenerExecutionFailedException.class);
  25.   assertThat(((ListenerExecutionFailedException) this.config.ehException).getGroupId()).isEqualTo(CONTAINER_ID);
  26. }

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

  1. Map<TopicPartition, OffsetAndMetadata> offsets = new LinkedHashMap<>();
  2. offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(1L));
  3. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  4. inOrder.verify(this.producer).commitTransaction();
  5. offsets.clear();
  6. offsets.put(new TopicPartition("foo", 0), new OffsetAndMetadata(2L));
  7. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  8. inOrder.verify(this.producer).commitTransaction();
  9. offsets.clear();
  10. offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(1L));
  11. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  12. inOrder.verify(this.producer).commitTransaction();
  13. inOrder.verify(this.consumer).seek(new TopicPartition("foo", 1), 1L);
  14. offsets.clear();
  15. offsets.put(new TopicPartition("foo", 1), new OffsetAndMetadata(2L));
  16. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  17. inOrder.verify(this.producer).commitTransaction();
  18. offsets.clear();
  19. offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(1L));
  20. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  21. inOrder.verify(this.producer).commitTransaction();
  22. offsets.clear();
  23. offsets.put(new TopicPartition("foo", 2), new OffsetAndMetadata(2L));
  24. inOrder.verify(this.producer).sendOffsetsToTransaction(offsets, CONTAINER_ID);
  25. inOrder.verify(this.producer).commitTransaction();
  26. inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId)
  3.     throws ProducerFencedException {
  4.   this.delegate.sendOffsetsToTransaction(offsets, consumerGroupId);
  5. }

代码示例来源：origin: linkedin/li-apache-kafka-clients

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets,
  3.                    String consumerGroupId) throws ProducerFencedException {
  4.  _producer.sendOffsetsToTransaction(offsets, consumerGroupId);
  5. }

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> map, String s)
  3.   throws ProducerFencedException {
  4.  producer.sendOffsetsToTransaction(map, s);
  5. }

代码示例来源：origin: io.zipkin.brave/brave-instrumentation-kafka-clients

  1. @Override
  2.  public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets,
  3.    String consumerGroupId) {
  4.   delegate.sendOffsetsToTransaction(offsets, consumerGroupId);
  5.  }
  6. }

代码示例来源：origin: com.github.combinedmq/combinedmq

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId) throws ProducerFencedException {
  3.   producer.sendOffsetsToTransaction(offsets, consumerGroupId);
  4. }

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId)
  3.     throws ProducerFencedException {
  4.   this.delegate.sendOffsetsToTransaction(offsets, consumerGroupId);
  5. }

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

  1. @Override
  2. public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> map, String s)
  3.   throws ProducerFencedException {
  4.  producer.sendOffsetsToTransaction(map, s);
  5. }

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

  1. verify(producer).send(captor.capture(), any(Callback.class));
  2. assertThat(captor.getValue()).isEqualTo(new ProducerRecord("bar", "baz"));
  3. inOrder.verify(producer, never()).sendOffsetsToTransaction(anyMap(), anyString());
  4. inOrder.verify(producer, never()).commitTransaction();
  5. inOrder.verify(producer).abortTransaction();

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

  1. InOrder inOrder = inOrder(producer);
  2. inOrder.verify(producer).beginTransaction();
  3. inOrder.verify(producer).sendOffsetsToTransaction(Collections.singletonMap(topicPartition,
  4.     new OffsetAndMetadata(0)), "group");
  5. inOrder.verify(producer).commitTransaction();
  6. inOrder.verify(producer).send(captor.capture(), any(Callback.class));
  7. assertThat(captor.getValue()).isEqualTo(new ProducerRecord("bar", "baz"));
  8. inOrder.verify(producer).sendOffsetsToTransaction(Collections.singletonMap(topicPartition,
  9.     new OffsetAndMetadata(1)), "group");
  10. inOrder.verify(producer).commitTransaction();

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

  1. verify(producer).send(captor.capture(), any(Callback.class));
  2. assertThat(captor.getValue()).isEqualTo(new ProducerRecord("bar", "baz"));
  3. inOrder.verify(producer, never()).sendOffsetsToTransaction(anyMap(), anyString());
  4. inOrder.verify(producer, never()).commitTransaction();
  5. inOrder.verify(producer).abortTransaction();

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

  1. inOrder.verify(producer).send(captor.capture(), any(Callback.class));
  2. assertThat(captor.getValue()).isEqualTo(new ProducerRecord("bar", "baz"));
  3. inOrder.verify(producer).sendOffsetsToTransaction(Collections.singletonMap(topicPartition,
  4.     new OffsetAndMetadata(1)), "group");
  5. inOrder.verify(producer).commitTransaction();

代码示例来源：origin: org.apache.kafka/kafka-streams

  1. producer.sendOffsetsToTransaction(consumedOffsetsAndMetadata, applicationId);
  2. producer.commitTransaction();
  3. transactionInFlight = false;

内容来源于网络，如有侵权，请联系作者删除！

Producer

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com