Skip to content

Commit

Permalink
DEVX-1881: microservices-orders updated bootstrap-servers cli arg
Browse files Browse the repository at this point in the history
  • Loading branch information
@rspurgeon
rspurgeon committed Jul 7, 2020
1 parent 859e5f8 commit ee6eb3c
Show file tree
Hide file tree
Showing 14 changed files with 21 additions and 21 deletions.
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/AddInventory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("c")
.longOpt("config-file").hasArg().desc("Java properties file with configurations for Kafka Clients").build())
.addOption(Option.builder("h")
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/EmailService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ private KafkaStreams processStreams(final String bootstrapServers,
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server")
.longOpt("bootstrap-servers")
.hasArg()
.desc("Kafka cluster bootstrap server string (ex: broker:9092)")
.build());
Expand Down Expand Up @@ -168,7 +168,7 @@ public static void main(final String[] args) throws Exception {
Schemas.configureSerdes(defaultConfig);

service.start(
cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("state-dir", "/tmp/kafka-streams-examples"),
defaultConfig);
addShutdownHookAndBlock(service);
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/FraudService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server")
.longOpt("bootstrap-servers")
.hasArg()
.desc("Kafka cluster bootstrap server string (ex: broker:9092)")
.build());
Expand Down Expand Up @@ -187,7 +187,7 @@ public static void main(final String[] args) throws Exception {
Schemas.configureSerdes(defaultConfig);

service.start(
cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("state-dir", "/tmp/kafka-streams-examples"),
defaultConfig);
addShutdownHookAndBlock(service);
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/InventoryService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ public void close() {
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server")
.longOpt("bootstrap-servers")
.hasArg()
.desc("Kafka cluster bootstrap server string (ex: broker:9092)")
.build());
Expand Down Expand Up @@ -220,7 +220,7 @@ public static void main(final String[] args) throws Exception {

final InventoryService service = new InventoryService();
service.start(
cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("state-dir", "/tmp/kafka-streams-examples"),
defaultConfig);
addShutdownHookAndBlock(service);
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/OrderDetailsService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ public void setEosEnabled(final boolean value) {
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server")
.longOpt("bootstrap-servers")
.hasArg()
.desc("Kafka cluster bootstrap server string (ex: broker:9092)")
.build());
Expand Down Expand Up @@ -240,7 +240,7 @@ public static void main(final String[] args) throws Exception {

final OrderDetailsService service = new OrderDetailsService();
service.start(
cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("state-dir", "/tmp/kafka-streams-examples"),
defaultConfig);
addShutdownHookAndBlock(service);
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/OrdersService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -418,7 +418,7 @@ private Callback callback(final AsyncResponse response, final String orderId) {
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("h")
Expand All @@ -438,7 +438,7 @@ public static void main(final String[] args) throws Exception {
return;
}

final String bootstrapServers = cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS);
final String bootstrapServers = cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS);
final String restHostname = cl.getOptionValue("hostname", "localhost");
final int restPort = Integer.parseInt(cl.getOptionValue("port", "5432"));
final String stateDir = cl.getOptionValue("state-dir", "/tmp/kafka-streams");
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/PostOrdersAndPayments.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("o")
Expand All @@ -92,7 +92,7 @@ public static void main(final String[] args) throws Exception {
return;
}

final String bootstrapServers = cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS);
final String bootstrapServers = cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS);
final String orderServiceUrl = cl.getOptionValue("order-service-url", "http://localhost:5432");
final int startingOrderId = Integer.parseInt(cl.getOptionValue("order-id", "1"));

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/confluent/examples/streams/microservices/ValidationsAggregatorService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -152,7 +152,7 @@ public void stop() {
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server")
.longOpt("bootstrap-servers")
.hasArg()
.desc("Kafka cluster bootstrap server string (ex: broker:9092)")
.build());
Expand Down Expand Up @@ -197,7 +197,7 @@ public static void main(final String[] args) throws Exception {
final ValidationsAggregatorService service = new ValidationsAggregatorService();

service.start(
cl.getOptionValue("bootstrap-server", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("bootstrap-servers", DEFAULT_BOOTSTRAP_SERVERS),
cl.getOptionValue("state-dir", "/tmp/kafka-streams-examples"),
defaultConfig);
addShutdownHookAndBlock(service);
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ConsumeCustomers.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ConsumeOrders.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ConsumePayments.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public class ConsumePayments {
public static void main(final String[] args) throws Exception {
final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ProduceCustomers.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ProduceOrders.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/io/confluent/examples/streams/microservices/util/ProducePayments.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ public static void main(final String[] args) throws Exception {

final Options opts = new Options();
opts.addOption(Option.builder("b")
.longOpt("bootstrap-server").hasArg().desc("Kafka cluster bootstrap server string").build())
.longOpt("bootstrap-servers").hasArg().desc("Kafka cluster bootstrap server string").build())
.addOption(Option.builder("s")
.longOpt("schema-registry").hasArg().desc("Schema Registry URL").build())
.addOption(Option.builder("c")
Expand Down

0 comments on commit ee6eb3c

Please sign in to comment.