Skip to content

Commit 790a36b

Browse files
poorbarcodemanas-ctds
authored andcommitted
remove unnecessary codes
(cherry picked from commit 232f0ef)
1 parent ec2037e commit 790a36b

File tree

2 files changed

+0
-25
lines changed

2 files changed

+0
-25
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/client/api/RawReader.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -44,19 +44,6 @@ static CompletableFuture<RawReader> create(PulsarClient client, String topic, St
4444
return future.thenApply(__ -> r);
4545
}
4646

47-
//<<<<<<< HEAD
48-
//=======
49-
// static CompletableFuture<RawReader> create(PulsarClient client,
50-
// ConsumerConfigurationData<byte[]> consumerConfiguration,
51-
// boolean createTopicIfDoesNotExist, boolean retryOnRecoverableErrors) {
52-
// CompletableFuture<Consumer<byte[]>> future = new CompletableFuture<>();
53-
// RawReader r = new RawReaderImpl((PulsarClientImpl) client,
54-
// consumerConfiguration, future, createTopicIfDoesNotExist, retryOnRecoverableErrors);
55-
// return future.thenApply(__ -> r);
56-
// }
57-
//
58-
//
59-
//>>>>>>> 37e160f78f ([fix][broker]Fix deadlock when compaction and topic deletion execute concurrently (#24366))
6047
/**
6148
* Get the topic for the reader.
6249
*

pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -67,18 +67,6 @@ public RawReaderImpl(PulsarClientImpl client, String topic, String subscription,
6767
retryOnRecoverableErrors);
6868
}
6969

70-
//<<<<<<< HEAD
71-
//=======
72-
// public RawReaderImpl(PulsarClientImpl client, ConsumerConfigurationData<byte[]> consumerConfiguration,
73-
// CompletableFuture<Consumer<byte[]>> consumerFuture,
74-
// boolean createTopicIfDoesNotExist, boolean retryOnRecoverableErrors) {
75-
// this.consumerConfiguration = consumerConfiguration;
76-
// consumer = new RawConsumerImpl(client, consumerConfiguration, consumerFuture, createTopicIfDoesNotExist,
77-
// retryOnRecoverableErrors);
78-
// }
79-
//
80-
//
81-
//>>>>>>> 37e160f78f ([fix][broker]Fix deadlock when compaction and topic deletion execute concurrently (#24366))
8270
@Override
8371
public String getTopic() {
8472
return consumerConfiguration.getTopicNames().stream()

0 commit comments

Comments
 (0)