Toggle navigation
Home
org.apache.pulsar.client.api.ConsumerConfiguration to org.apache.pulsar.client.impl.conf.ConsumerConfigurationData
No. of Instances - 17
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
ConsumerConfiguration
to
ConsumerConfigurationData
Rename Method invocation
setAckTimeout
to
setAckTimeoutMillis
setAckTimeout
to
setAckTimeoutMillis
setAckTimeout
to
setAckTimeoutMillis
Add or Remove Method invocation
client.getPartitionedTopicMetadata(topicName).thenAccept(metadata -> { if (log.isDebugEnabled()) { log.debug("Received topic {} metadata.partitions: {}",topicName,metadata.partitions); } List<CompletableFuture<Consumer>> futureList; if (metadata.partitions > 1) { this.topics.putIfAbsent(topicName,metadata.partitions); numberTopicPartitions.addAndGet(metadata.partitions); partitionNumber.addAndGet(metadata.partitions); futureList=IntStream.range(0,partitionNumber.get()).mapToObj(partitionIndex -> { String partitionName=DestinationName.get(topicName).getPartition(partitionIndex).toString(); CompletableFuture<Consumer> subFuture=new CompletableFuture<Consumer>(); ConsumerImpl newConsumer=new ConsumerImpl(client,partitionName,subscription,internalConfig,client.externalExecutorProvider().getExecutor(),partitionIndex,subFuture); consumers.putIfAbsent(newConsumer.getTopic(),newConsumer); return subFuture; } ).collect(Collectors.toList()); } else { this.topics.putIfAbsent(topicName,1); numberTopicPartitions.incrementAndGet(); partitionNumber.incrementAndGet(); CompletableFuture<Consumer> subFuture=new CompletableFuture<Consumer>(); ConsumerImpl newConsumer=new ConsumerImpl(client,topicName,subscription,internalConfig,client.externalExecutorProvider().getExecutor(),0,subFuture); consumers.putIfAbsent(newConsumer.getTopic(),newConsumer); futureList=Lists.newArrayList(subFuture); } FutureUtil.waitForAll(futureList).thenAccept(finalFuture -> { try { if (numberTopicPartitions.get() > maxReceiverQueueSize) { setMaxReceiverQueueSize(numberTopicPartitions.get()); } int numTopics=this.topics.values().stream().mapToInt(Integer::intValue).sum(); checkState(numberTopicPartitions.get() == numTopics,"numberTopicPartitions " + numberTopicPartitions.get() + " not equals expected: "+ numTopics); startReceivingMessages(consumers.values().stream().filter(consumer1 -> { String consumerTopicName=consumer1.getTopic(); if (DestinationName.get(consumerTopicName).getPartitionedTopicName().equals(topicName)) { return true; } else { return false; } } ).collect(Collectors.toList())); subscribeResult.complete(null); log.info("[{}] [{}] Success subscribe new topic {} in topics consumer, numberTopicPartitions {}",topic,subscription,topicName,numberTopicPartitions.get()); if (this.namespaceName == null) { this.namespaceName=DestinationName.get(topicName).getNamespaceObject(); } return; } catch ( PulsarClientException e) { handleSubscribeOneTopicError(topicName,e); subscribeResult.completeExceptionally(e); } } ).exceptionally(ex -> { handleSubscribeOneTopicError(topicName,ex); subscribeResult.completeExceptionally(ex); return null; } ); } )
to
client.getPartitionedTopicMetadata(topicName).thenAccept(metadata -> { if (log.isDebugEnabled()) { log.debug("Received topic {} metadata.partitions: {}",topicName,metadata.partitions); } List<CompletableFuture<Consumer>> futureList; if (metadata.partitions > 1) { this.topics.putIfAbsent(topicName,metadata.partitions); numberTopicPartitions.addAndGet(metadata.partitions); partitionNumber.addAndGet(metadata.partitions); futureList=IntStream.range(0,partitionNumber.get()).mapToObj(partitionIndex -> { String partitionName=DestinationName.get(topicName).getPartition(partitionIndex).toString(); CompletableFuture<Consumer> subFuture=new CompletableFuture<Consumer>(); ConsumerImpl newConsumer=new ConsumerImpl(client,partitionName,internalConfig,client.externalExecutorProvider().getExecutor(),partitionIndex,subFuture); consumers.putIfAbsent(newConsumer.getTopic(),newConsumer); return subFuture; } ).collect(Collectors.toList()); } else { this.topics.putIfAbsent(topicName,1); numberTopicPartitions.incrementAndGet(); partitionNumber.incrementAndGet(); CompletableFuture<Consumer> subFuture=new CompletableFuture<Consumer>(); ConsumerImpl newConsumer=new ConsumerImpl(client,topicName,internalConfig,client.externalExecutorProvider().getExecutor(),0,subFuture); consumers.putIfAbsent(newConsumer.getTopic(),newConsumer); futureList=Lists.newArrayList(subFuture); } FutureUtil.waitForAll(futureList).thenAccept(finalFuture -> { try { if (numberTopicPartitions.get() > maxReceiverQueueSize) { setMaxReceiverQueueSize(numberTopicPartitions.get()); } int numTopics=this.topics.values().stream().mapToInt(Integer::intValue).sum(); checkState(numberTopicPartitions.get() == numTopics,"numberTopicPartitions " + numberTopicPartitions.get() + " not equals expected: "+ numTopics); startReceivingMessages(consumers.values().stream().filter(consumer1 -> { String consumerTopicName=consumer1.getTopic(); if (DestinationName.get(consumerTopicName).getPartitionedTopicName().equals(topicName)) { return true; } else { return false; } } ).collect(Collectors.toList())); subscribeResult.complete(null); log.info("[{}] [{}] Success subscribe new topic {} in topics consumer, numberTopicPartitions {}",topic,subscription,topicName,numberTopicPartitions.get()); if (this.namespaceName == null) { this.namespaceName=DestinationName.get(topicName).getNamespaceObject(); } return; } catch ( PulsarClientException e) { handleSubscribeOneTopicError(topicName,e); subscribeResult.completeExceptionally(e); } } ).exceptionally(ex -> { handleSubscribeOneTopicError(topicName,ex); subscribeResult.completeExceptionally(ex); return null; } ); } )
conf.getReadCompacted()
to
conf.isReadCompacted()