Skip to content

Commit

Permalink
Using https for Confluent repo
Browse files Browse the repository at this point in the history
  • Loading branch information
ekoutanov committed Jan 30, 2020
1 parent c30cf37 commit c1bf994
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
5 changes: 3 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -20,11 +20,12 @@ This project is a reboot of Kafdrop 2.x, dragged kicking and screaming into the
* **View consumer groups** — per-partition parked offsets, combined and per-partition lag
* **Create new topics**
* **View ACLs**
* **Support for Azure Event Hubs**

# Requirements

* Java 11 or newer
* Kafka (version 0.11.0 or newer)
* Kafka (version 0.11.0 or newer) or Azure Event Hubs

Optional, additional integration:

Expand Down Expand Up @@ -221,7 +222,7 @@ docker run -d --rm -p 9000:9000 \
|`KAFKA_KEYSTORE` |Private key for mutual TLS authentication (base-64 encoded).
|`SERVER_SERVLET_CONTEXTPATH`|The context path to serve requests on (must end with a `/`). Defaults to `/`.
|`SERVER_PORT` |The web server port to listen on. Defaults to `9000`.
|`CMD_ARGS` |Command line arguments to kafkdrop like `--message.format` or `--protobufdesc.directory` or `--server.port`.
|`CMD_ARGS` |Command line arguments to Kafdrop, e.g. `--message.format` or `--protobufdesc.directory` or `--server.port`.

##### Advanced configuration
|Name |Description
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
</repository>
<repository>
<id>confluent</id>
<url>http://packages.confluent.io/maven/</url>
<url>https://packages.confluent.io/maven/</url>
</repository>
</repositories>

Expand Down
3 changes: 1 addition & 2 deletions src/main/java/kafdrop/service/KafkaHighLevelAdminClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -108,8 +108,7 @@ Map<String, Config> describeTopicConfigs(Set<String> topicNames) {
} catch (InterruptedException | ExecutionException e) {
if (e.getCause() instanceof UnsupportedVersionException) {
return Map.of();
}
if (e.getCause() instanceof TopicAuthorizationException) {
} else if (e.getCause() instanceof TopicAuthorizationException) {
printAcls();
}
throw new KafkaAdminClientException(e);
Expand Down

0 comments on commit c1bf994

Please sign in to comment.