This repository was archived by the owner on Jan 24, 2024. It is now read-only.
File tree Expand file tree Collapse file tree
src/main/java/io/streamnative/pulsar/handlers/kop Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222 <parent >
2323 <groupId >io.streamnative.pulsar.handlers</groupId >
2424 <artifactId >pulsar-protocol-handler-kafka-parent</artifactId >
25- <version >2.6.2-SNAPSHOT </version >
25+ <version >2.7.0 </version >
2626 </parent >
2727
2828 <groupId >io.streamnative.pulsar.handlers</groupId >
Original file line number Diff line number Diff line change 3636import lombok .extern .slf4j .Slf4j ;
3737import org .apache .bookkeeper .common .util .ReflectionUtils ;
3838import org .apache .bookkeeper .conf .ServerConfiguration ;
39+ import org .apache .bookkeeper .discover .BookieServiceInfo ;
3940import org .apache .bookkeeper .proto .BookieServer ;
4041import org .apache .bookkeeper .replication .AutoRecoveryMain ;
4142import org .apache .bookkeeper .stats .StatsProvider ;
@@ -130,7 +131,8 @@ && isBlank(starterArguments.bookieConfigFile)) {
130131 if (starterArguments .runBookie ) {
131132 checkNotNull (bookieConfig , "No ServerConfiguration for Bookie" );
132133 checkNotNull (bookieStatsProvider , "No Stats Provider for Bookie" );
133- bookieServer = new BookieServer (bookieConfig , bookieStatsProvider .getStatsLogger ("" ));
134+ bookieServer = new BookieServer (
135+ bookieConfig , bookieStatsProvider .getStatsLogger ("" ), BookieServiceInfo .NO_INFO );
134136 } else {
135137 bookieServer = null ;
136138 }
Original file line number Diff line number Diff line change 2929
3030 <groupId >io.streamnative.pulsar.handlers</groupId >
3131 <artifactId >pulsar-protocol-handler-kafka-parent</artifactId >
32- <version >2.6.2-SNAPSHOT </version >
32+ <version >2.7.0 </version >
3333 <name >StreamNative :: Pulsar Protocol Handler :: KoP Parent</name >
3434 <description >Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler.</description >
3535
4747 <log4j2 .version>2.13.3</log4j2 .version>
4848 <lombok .version>1.18.4</lombok .version>
4949 <mockito .version>2.22.0</mockito .version>
50- <pulsar .version>2.6.2 .0</pulsar .version>
50+ <pulsar .version>2.7 .0</pulsar .version>
5151 <slf4j .version>1.7.25</slf4j .version>
5252 <spotbugs-annotations .version>3.1.8</spotbugs-annotations .version>
5353 <testcontainers .version>1.12.5</testcontainers .version>
Original file line number Diff line number Diff line change 2222 <parent >
2323 <groupId >io.streamnative.pulsar.handlers</groupId >
2424 <artifactId >pulsar-protocol-handler-kafka-parent</artifactId >
25- <version >2.6.2-SNAPSHOT </version >
25+ <version >2.7.0 </version >
2626 </parent >
2727
2828 <groupId >io.streamnative.pulsar.handlers</groupId >
You can’t perform that action at this time.
0 commit comments