org.apache.kafka.clients.consumer.Consumer.unsubscribe()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(299)

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

Consumer.unsubscribe介绍

暂无

代码示例

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

  1. @Override public void unsubscribe() {
  2.  delegate.unsubscribe();
  3. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. @Override
  2. public String getSampleMessage(final String topic) {
  3.  String message = null;
  4.  if (listTopics().contains(topic)) {
  5.   try (Consumer<String, String> kafkaConsumer = kafkaConsumerFactory.createConsumer()) {
  6.    kafkaConsumer.assign(kafkaConsumer.partitionsFor(topic).stream()
  7.     .map(partitionInfo -> new TopicPartition(topic, partitionInfo.partition()))
  8.     .collect(Collectors.toList()));
  9.    kafkaConsumer.assignment().stream()
  10.     .filter(p -> (kafkaConsumer.position(p) - 1) >= 0)
  11.     .forEach(p -> kafkaConsumer.seek(p, kafkaConsumer.position(p) - 1));
  12.    final ConsumerRecords<String, String> records = kafkaConsumer.poll(KAFKA_CONSUMER_TIMEOUT);
  13.    message = records.isEmpty() ? null : records.iterator().next().value();
  14.    kafkaConsumer.unsubscribe();
  15.   }
  16.  }
  17.  return message;
  18. }

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void stopContainerAfterException() throws Exception {
  4.   assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
  5.   assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();
  6.   assertThat(this.config.errorLatch.await(10, TimeUnit.SECONDS)).isTrue();
  7.   assertThat(this.config.closeLatch.await(10, TimeUnit.SECONDS)).isTrue();
  8.   MessageListenerContainer container = this.registry.getListenerContainer(CONTAINER_ID);
  9.   assertThat(container.isRunning()).isFalse();
  10.   InOrder inOrder = inOrder(this.consumer);
  11.   inOrder.verify(this.consumer).subscribe(any(Collection.class), any(ConsumerRebalanceListener.class));
  12.   inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  13.   inOrder.verify(this.consumer).wakeup();
  14.   inOrder.verify(this.consumer).unsubscribe();
  15.   inOrder.verify(this.consumer).close();
  16.   inOrder.verifyNoMoreInteractions();
  17. }

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void stopContainerAfterException() throws Exception {
  4.   assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
  5.   assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();
  6.   assertThat(this.config.errorLatch.await(10, TimeUnit.SECONDS)).isTrue();
  7.   assertThat(this.config.closeLatch.await(10, TimeUnit.SECONDS)).isTrue();
  8.   MessageListenerContainer container = this.registry.getListenerContainer(CONTAINER_ID);
  9.   assertThat(container.isRunning()).isFalse();
  10.   InOrder inOrder = inOrder(this.consumer);
  11.   inOrder.verify(this.consumer).subscribe(any(Collection.class), any(ConsumerRebalanceListener.class));
  12.   inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  13.   inOrder.verify(this.consumer).wakeup();
  14.   inOrder.verify(this.consumer).unsubscribe();
  15.   inOrder.verify(this.consumer).close();
  16.   inOrder.verifyNoMoreInteractions();
  17.   assertThat(this.config.count).isEqualTo(4);
  18.   assertThat(this.config.contents.toArray()).isEqualTo(new String[]
  19.       { "foo", "bar", "baz", "qux" });
  20. }

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void stopContainerAfterException() throws Exception {
  4.   assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
  5.   assertThat(this.config.commitLatch.await(10, TimeUnit.SECONDS)).isTrue();
  6.   assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();
  7.   assertThat(this.config.errorLatch.await(10, TimeUnit.SECONDS)).isTrue();
  8.   assertThat(this.config.closeLatch.await(10, TimeUnit.SECONDS)).isTrue();
  9.   MessageListenerContainer container = this.registry.getListenerContainer(CONTAINER_ID);
  10.   assertThat(container.isRunning()).isFalse();
  11.   InOrder inOrder = inOrder(this.consumer);
  12.   inOrder.verify(this.consumer).subscribe(any(Collection.class), any(ConsumerRebalanceListener.class));
  13.   inOrder.verify(this.consumer).poll(Duration.ofMillis(ContainerProperties.DEFAULT_POLL_TIMEOUT));
  14.   inOrder.verify(this.consumer).commitSync(
  15.       Collections.singletonMap(new TopicPartition("foo", 0), new OffsetAndMetadata(1L)));
  16.   inOrder.verify(this.consumer).commitSync(
  17.       Collections.singletonMap(new TopicPartition("foo", 0), new OffsetAndMetadata(2L)));
  18.   inOrder.verify(this.consumer).commitSync(
  19.       Collections.singletonMap(new TopicPartition("foo", 1), new OffsetAndMetadata(1L)));
  20.   inOrder.verify(this.consumer).wakeup();
  21.   inOrder.verify(this.consumer).unsubscribe();
  22.   inOrder.verify(this.consumer).close();
  23.   inOrder.verifyNoMoreInteractions();
  24.   assertThat(this.config.count).isEqualTo(4);
  25.   assertThat(this.config.contents.toArray()).isEqualTo(new String[]
  26.       { "foo", "bar", "baz", "qux" });
  27. }

代码示例来源：origin: rayokota/kafka-graphs

  1. @Override
  2. public void unsubscribe() {
  3.   kafkaConsumer.unsubscribe();
  4. }

代码示例来源：origin: vert-x3/vertx-kafka-client

  1. @Override
  2. public KafkaReadStream<K, V> unsubscribe(Handler<AsyncResult<Void>> completionHandler) {
  3.  this.submitTask((consumer, future) -> {
  4.   consumer.unsubscribe();
  5.   if (future != null) {
  6.    future.complete();
  7.   }
  8.  }, completionHandler);
  9.  return this;
  10. }

代码示例来源：origin: com.hotels.road/road-offramp-kafka

  1. @Override
  2. public void close() {
  3.  try {
  4.   consumer.unsubscribe();
  5.   consumer.close();
  6.   log.info("Closed KafkaConsumer");
  7.  } catch (org.apache.kafka.common.errors.InterruptException e) {
  8.   log.error("Interrupted while closing KafkaConsumer");
  9.   Thread.currentThread().interrupt();
  10.  }
  11. }

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

  1. @Override
  2. public void unsubscribe() {
  3.  // Clear all the state of the topic in consumer record processor.
  4.  _consumerRecordsProcessor.clear();
  5.  _kafkaConsumer.unsubscribe();
  6. }

代码示例来源：origin: authorjapps/zerocode

  1. public static void handleSeekOffset(ConsumerLocalConfigs effectiveLocal, Consumer consumer) {
  2.   String seek = effectiveLocal.getSeek();
  3.   if (!isEmpty(seek)) {
  4.     String[] seekPosition = effectiveLocal.getSeekTopicPartitionOffset();
  5.     TopicPartition topicPartition = new TopicPartition(seekPosition[0], parseInt(seekPosition[1]));
  6.     Set<TopicPartition> topicPartitions = new HashSet<>();
  7.     topicPartitions.add(topicPartition);
  8.     consumer.unsubscribe();
  9.     consumer.assign(topicPartitions);
  10.     consumer.seek(topicPartition, parseLong(seekPosition[2]));
  11.   }
  12. }

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

  1. @Override
  2.   public void close() {
  3.     super.close();
  4.     currentRow = null;
  5.     consumer.unsubscribe();
  6.     consumer.close();
  7.   }
  8. }

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

  1. @Override
  2.   public void close() {
  3.     super.close();
  4.     currentRow = null;
  5.     consumer.unsubscribe();
  6.     consumer.close();
  7.   }
  8. }

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

  1. private void enforceRebalance() {
  2.   consumer.unsubscribe();
  3.   consumer.subscribe(builder.sourceTopicPattern(), rebalanceListener);
  4. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

  1. private void closeConsumer(final Consumer<?, ?> consumer) {
  2.   consumerClosedCountRef.incrementAndGet();
  3.   try {
  4.     consumer.unsubscribe();
  5.   } catch (Exception e) {
  6.     logger.warn("Failed while unsubscribing " + consumer, e);
  7.   }
  8.   try {
  9.     consumer.close();
  10.   } catch (Exception e) {
  11.     logger.warn("Failed while closing " + consumer, e);
  12.   }
  13. }

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

Consumer

相关文章

    查看更多

    热门标签

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

    最新文章

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