justinrlee commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1377448071
Sample outputs for various scenarios here. Testing these configuration
combinations:
* CLI output with no params
* Connection to insecure cluster with `--bootstrap-server` flag
* Connection to insecure cluster with client property file without bootstrap
server (**expected to fail**)
* Connection to insecure cluster with client property file with bootstrap
server
* Connection to insecure cluster with `--bootstrap-server` flag _and_ client
property file (without bootstrap server)
* Connection to insecure cluster with `--bootstrap-server` flag _and_ client
property file (with bootstrap server)
* Connection to insecure cluster with `--bootstrap-server` flag _and_ client
property file (with invalid bootstrap server)
* Connection to secured cluster (SASL_SSL w/ PLAIN) with
`--bootstrap-server` and client property file (without bootstrap server)
* Connection to secured cluster (SASL_SSL w/ PLAIN) with client property
file (without bootstrap server) (**expected to fail**)
* Connection to secured cluster (SASL_SSL w/ PLAIN) with client property
file (with bootstrap server)
* Connection to secured cluster (SASL_SSL w/ PLAIN) with
`--bootstrap-server` and client property file (with bootstrap server)
* Connection to secured cluster (SASL_SSL w/ PLAIN) with
`--bootstrap-server` and client property file (with invalid bootstrap server)
## Configurations
Insecure cluster config without bootstrap looks like this:
```config
security.protocol=PLAINTEXT
```
Insecure cluster is accessed via `localhost:9092`; client property file
looks like this:
```config
bootstrap.servers=localhost:9092
security.protocol=PLAINTEXT
```
Insecure client property file with invalid bootstrap server looks like this
(should be overridden if bootstrap is provided as flag)
```config
bootstrap.servers=fake:9092
security.protocol=PLAINTEXT
```
Secure cluster is a Confluent Cloud cluster at
`pkc-2396y.us-east-1.aws.confluent.cloud:9092` (API key was deleted after
running tests but before adding this comment).
Secure cluster config without bootstrap looks like this:
```config
ssl.endpoint.identification.algorithm=https
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="LRIC7QZ4J6SHYT3F"
password="1sPliA/u205BVPlGRBnx0RF4n5cckdYeTQsSMdKZsMK3ael1NiSRuHF7tGcf11bE";
```
Secure cluster config with bootstrap looks like this:
```config
bootstrap.servers=pkc-2396y.us-east-1.aws.confluent.cloud:9092
ssl.endpoint.identification.algorithm=https
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="LRIC7QZ4J6SHYT3F"
password="1sPliA/u205BVPlGRBnx0RF4n5cckdYeTQsSMdKZsMK3ael1NiSRuHF7tGcf11bE";
```
Secure cluster config with invalid bootstrap looks like this:
```config
bootstrap.servers=fake:9092
ssl.endpoint.identification.algorithm=https
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="LRIC7QZ4J6SHYT3F"
password="1sPliA/u205BVPlGRBnx0RF4n5cckdYeTQsSMdKZsMK3ael1NiSRuHF7tGcf11bE";
```
## `kafka-broker-api-versions.sh`
```
+ ./bin/kafka-broker-api-versions.sh
This tool helps to retrieve broker version information.
Option Description
------ -----------
--bootstrap-server <String: server(s) The server to connect to. Can also be
to use for bootstrapping> specified with 'bootstrap.servers'
in the property file.
--command-config <String: command A property file containing configs to
config property file> be passed to Admin Client.
--help Print usage information.
--version Display Kafka version.
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092
localhost:9092 (id: 1 rack: null) -> (
# ... output suppressed
)
```
(expected to fail):
```
+ ./bin/kafka-broker-api-versions.sh --command-config insecure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$AdminConfig.<init>(BrokerApiVersionsCommand.scala:265)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$.create(BrokerApiVersionsCommand.scala:269)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$.create(BrokerApiVersionsCommand.scala:267)
at
kafka.admin.BrokerApiVersionsCommand$.createAdminClient(BrokerApiVersionsCommand.scala:79)
at
kafka.admin.BrokerApiVersionsCommand$.execute(BrokerApiVersionsCommand.scala:60)
at
kafka.admin.BrokerApiVersionsCommand$.main(BrokerApiVersionsCommand.scala:55)
at
kafka.admin.BrokerApiVersionsCommand.main(BrokerApiVersionsCommand.scala)
```
```
+ ./bin/kafka-broker-api-versions.sh --command-config
insecure-with-bootstrap.properties
localhost:9092 (id: 1 rack: null) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092
--command-config insecure.properties
localhost:9092 (id: 1 rack: null) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092
--command-config insecure-with-bootstrap.properties
localhost:9092 (id: 1 rack: null) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server localhost:9092
--command-config insecure-with-invalid.properties
localhost:9092 (id: 1 rack: null) -> (
# ... output suppressed
)
```
(expected to fail):
```
+ ./bin/kafka-broker-api-versions.sh --command-config secure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$AdminConfig.<init>(BrokerApiVersionsCommand.scala:265)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$.create(BrokerApiVersionsCommand.scala:269)
at
kafka.admin.BrokerApiVersionsCommand$AdminClient$.create(BrokerApiVersionsCommand.scala:267)
at
kafka.admin.BrokerApiVersionsCommand$.createAdminClient(BrokerApiVersionsCommand.scala:79)
at
kafka.admin.BrokerApiVersionsCommand$.execute(BrokerApiVersionsCommand.scala:60)
at
kafka.admin.BrokerApiVersionsCommand$.main(BrokerApiVersionsCommand.scala:55)
at
kafka.admin.BrokerApiVersionsCommand.main(BrokerApiVersionsCommand.scala)
```
```
+ ./bin/kafka-broker-api-versions.sh --command-config
secure-with-bootstrap.properties
b38-pkc-2396y.us-east-1.aws.confluent.cloud:9092 (id: 38 rack: 2) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config secure.properties
b38-pkc-2396y.us-east-1.aws.confluent.cloud:9092 (id: 38 rack: 2) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-bootstrap.properties
b38-pkc-2396y.us-east-1.aws.confluent.cloud:9092 (id: 38 rack: 2) -> (
# ... output suppressed
)
```
```
+ ./bin/kafka-broker-api-versions.sh --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-invalid.properties
b38-pkc-2396y.us-east-1.aws.confluent.cloud:9092 (id: 38 rack: 2) -> (
# ... output suppressed
)
```
## `kafka-topics.sh`
(expected to fail):
```
+ ./bin/kafka-topics.sh --list
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.TopicCommand$TopicService$.createAdminClient(TopicCommand.scala:205)
at kafka.admin.TopicCommand$TopicService$.apply(TopicCommand.scala:209)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:50)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
+ ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
__consumer_offsets
test
```
(expected to fail):
```
+ ./bin/kafka-topics.sh --list --command-config insecure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.TopicCommand$TopicService$.createAdminClient(TopicCommand.scala:205)
at kafka.admin.TopicCommand$TopicService$.apply(TopicCommand.scala:209)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:50)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
```
```
+ ./bin/kafka-topics.sh --list --command-config
insecure-with-bootstrap.properties
__consumer_offsets
test
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
--command-config insecure.properties
__consumer_offsets
test
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
--command-config insecure-with-bootstrap.properties
__consumer_offsets
test
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
--command-config insecure-with-invalid.properties
__consumer_offsets
test
```
(expected to fail):
```
+ ./bin/kafka-topics.sh --list --command-config secure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.TopicCommand$TopicService$.createAdminClient(TopicCommand.scala:205)
at kafka.admin.TopicCommand$TopicService$.apply(TopicCommand.scala:209)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:50)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
```
```
+ ./bin/kafka-topics.sh --list --command-config
secure-with-bootstrap.properties
confluent.connect-configs
confluent.connect-offsets
confluent.connect-status
hello
test
test1
test2
topic_3
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config secure.properties
confluent.connect-configs
confluent.connect-offsets
confluent.connect-status
hello
test
test1
test2
topic_3
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-bootstrap.properties
confluent.connect-configs
confluent.connect-offsets
confluent.connect-status
hello
test
test1
test2
topic_3
```
```
+ ./bin/kafka-topics.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-invalid.properties
confluent.connect-configs
confluent.connect-offsets
confluent.connect-status
hello
test
test1
test2
topic_3
```
## `kafka-consumer-groups.sh`
(expected to fail):
```
+ ./bin/kafka-consumer-groups.sh --list
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:697)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.<init>(ConsumerGroupCommand.scala:176)
at kafka.admin.ConsumerGroupCommand$.run(ConsumerGroupCommand.scala:67)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
console-consumer-15088
```
(expected to fail):
```
+ ./bin/kafka-consumer-groups.sh --list --command-config insecure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:697)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.<init>(ConsumerGroupCommand.scala:176)
at kafka.admin.ConsumerGroupCommand$.run(ConsumerGroupCommand.scala:67)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
```
```
+ ./bin/kafka-consumer-groups.sh --list --command-config
insecure-with-bootstrap.properties
console-consumer-15088
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
--command-config insecure.properties
console-consumer-15088
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
--command-config insecure-with-bootstrap.properties
console-consumer-15088
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
--command-config insecure-with-invalid.properties
console-consumer-15088
```
(expected to fail):
```
+ ./bin/kafka-consumer-groups.sh --list --command-config secure.properties
Exception in thread "main" org.apache.kafka.common.config.ConfigException:
Missing required configuration "bootstrap.servers" which has no default value.
at
org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
at
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
at
org.apache.kafka.clients.admin.AdminClientConfig.<init>(AdminClientConfig.java:244)
at org.apache.kafka.clients.admin.Admin.create(Admin.java:134)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:697)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.<init>(ConsumerGroupCommand.scala:176)
at kafka.admin.ConsumerGroupCommand$.run(ConsumerGroupCommand.scala:67)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
```
```
+ ./bin/kafka-consumer-groups.sh --list --command-config
secure-with-bootstrap.properties
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config secure.properties
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-bootstrap.properties
```
```
+ ./bin/kafka-consumer-groups.sh --list --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --command-config
secure-with-invalid.properties
```
## `kafka-console-producer.sh`
(expected to fail):
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:462)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:290)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:317)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:302)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:44)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:436)
... 5 more
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
localhost:9092
```
(expected to fail):
```
+ ./bin/kafka-console-producer.sh --topic test --producer.config
insecure.properties
+ echo test
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:462)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:290)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:317)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:302)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:44)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:436)
... 5 more
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --producer.config
insecure-with-bootstrap.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
localhost:9092 --producer.config insecure.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
localhost:9092 --producer.config insecure-with-bootstrap.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
localhost:9092 --producer.config insecure-with-invalid.properties
```
(expected to fail):
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --producer.config
secure.properties
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:462)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:290)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:317)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:302)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:44)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:436)
... 5 more
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --producer.config
secure-with-bootstrap.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --producer.config secure.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --producer.config
secure-with-bootstrap.properties
```
```
+ echo test
+ ./bin/kafka-console-producer.sh --topic test --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --producer.config
secure-with-invalid.properties
```
## `kafka-console-consumer.sh`
(expected to fail):
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1
[2023-01-10 15:18:31,025] ERROR Unknown error when running consumer:
(kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:829)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:665)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:646)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:66)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:731)
... 5 more
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server localhost:9092
hello
Processed a total of 1 messages
```
(expected to fail):
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --consumer.config insecure.properties
[2023-01-10 15:18:35,373] ERROR Unknown error when running consumer:
(kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:829)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:665)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:646)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:66)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:731)
... 5 more
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --consumer.config insecure-with-bootstrap.properties
hello
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server localhost:9092 --consumer.config
insecure.properties
hello
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server localhost:9092 --consumer.config
insecure-with-bootstrap.properties
hello
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server localhost:9092 --consumer.config
insecure-with-invalid.properties
hello
Processed a total of 1 messages
```
(expected to fail):
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --consumer.config secure.properties
[2023-01-10 15:18:46,651] ERROR Unknown error when running consumer:
(kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:829)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:665)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:646)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:66)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable
bootstrap urls given in bootstrap.servers
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89)
at
org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48)
at
org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:731)
... 5 more
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --consumer.config secure-with-bootstrap.properties
test
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --consumer.config secure.properties
hello
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --consumer.config
secure-with-bootstrap.properties
test test 123 test
Processed a total of 1 messages
```
```
+ ./bin/kafka-console-consumer.sh --topic test --from-beginning
--max-messages 1 --bootstrap-server
pkc-2396y.us-east-1.aws.confluent.cloud:9092 --consumer.config
secure-with-invalid.properties
test test 123 test
Processed a total of 1 messages
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
