|
Check inetaddress.isReachable.
It is similar to ping
|
|
|
|
|
In my app I'm using JNI, and because of that I have to add into User/System Path the location to jvm.dll from JRE\bin\server. To add a variable in User Path it doesn't require administrator rights, so I'm taking this approach. To add it I'm using REG ADD from CMD with the following functions. The problem that I have is that after I'm adding the variable into Path, the software still doesn't see it and returns the error "jvm.dll not found", but if I restart the computer, then it runs fine and sees the variable. Also after I'm adding it, if I manually go into User Path and double click to edit the variable, and simply press enter without changing anything, then it doesn't require the restart. Does it have something to do with the code/way I'm adding the variable? What should I do to get past this and to get it working without the user/client having to restart the computer before it is working?
Function to run CMD:
std::string executeCMD(const char* cmd) {
std::string result;
std::array<char, 128> buffer;
std::unique_ptr<FILE, decltype(&_pclose)> pipe(_popen(cmd, "r"), _pclose);
if (!pipe) {
return "ErrorCMD";
}
while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) {
result += buffer.data();
}
return result;
}
Use of the function:
resultCMD.insert(0, "reg add \"HKEY_CURRENT_USER\\Environment\" /v PATH /t REG_EXPAND_SZ /d \"");
resultCMD.append("\" /f");
executeCMD(resultCMD.c_str());
resultCMD is a std::string which contains the values that were in Path and also the value that I'm adding under the following format with "C:\Program Files\Eclipse Adoptium\jre-18.0.1.10-hotspot\bin\server" being added after I use the function from above:
C:\Program Files\Eclipse Adoptium\jre-18.0.1.10-hotspot\bin\server;D:\Program Files (x86)\VMware\VMware Player\bin\;D:\Program Files\Python\Python310\Scripts\;D:\Program Files\Python\Python310\;C:\Windows\system32;C:\Windows; ...and the rest of the variables, this was as an example, after each variable they have a ;
|
|
|
|
|
I ended up switching to use RegOpenKeyExA, RegQueryValueExA, RegCreateKeyEx, RegSetValueExA to get and add the values into Path, that way I can use SendNotifyMessage(HWND_BROADCAST, WM_SETTINGCHANGE, 0, (LPARAM)TEXT("Environment")); to get past the need for a system restart/logout.
|
|
|
|
|
There is also the “setx” command that can help with that.
I ran into similar problems setting info into the registry directly.
|
|
|
|
|
If I'm planning to distribute some software that uses Java, can I simply add in it's folder structure jre-8u333-windows-x64.exe (or other versions, this was the latest) for those that don't have it and prompt them to install it? Or beside that I need to add a file with Oracle license and have the user tick a box that they agree? Or do I have to buy something from Oracle?
The software will be free but it contains microtransactions for profit.
|
|
|
|
|
If you're bundling Oracle software, then you go with what the Oracle license says.
"Before entering on an understanding, I have meditated for a long time, and have foreseen what might happen. It is not genius which reveals to me suddenly, secretly, what I have to say or to do in a circumstance unexpected by other people; it is reflection, it is meditation." - Napoleon I
|
|
|
|
|
|
I'm using jdk1.8.0_333 / jre1.8.0_333. Do you know if this is a problem or not? Or I need to try to switch to a new version to be free? I'm not really going to make money from my first release, so I would like to try to keep it free.
Also I've seen that there is another source for Java: OpenJDK[^] / OpenJDK JDK 18.0.1.1 GA Release[^]. Is this one free, while the one from Oracle you need a subscription but contains some more advanced features/libraries?
|
|
|
|
|
For the definitive answer that's going to deal with money, the ONLY people you should be asking this question of is Oracle Support.
|
|
|
|
|
Because this is a issue that can lead to financial/law problems I took a look at JDK's and I found Adoptium[^]. Do you know if this is free for commercial use? I see that they have JDK and JRE. I will try to contact them as well, but for sure it will take quite a long time before they respond.
|
|
|
|
|
I don't do Java.
The only reason I know about the licensing is because of the licensing requirements at work.
|
|
|
|
|
public class student{
private int ID;
private String Name;
Student class constructor
student(int id, String name){
this.ID = id;
this.Name = name;}
public int getid(){
return this.ID;}
public String Getname(){
return this.Name;}
public void SETid(int i){
this.ID = i;}
public void sETNAme(String n){
this.Name=n;}
method to display data
public void display() {
System.out.println("Student id is: " + id + " "
+ "and Student name is: "
+ Name;);
System.out.println();
}}
|
|
|
|
|
No.
Even if you'd asked nicely, you haven't bothered to tell us what "the error" is.
Dumping your code without explanation and demanding that someone "solve the error" is a great way to alienate people, and ensure nobody wants to help you.
"These people looked deep within my soul and assigned me a number based on the order in which I joined."
- Homer
|
|
|
|
|
Let's start by formatting the code and adding ;line numbers so it is actually readable. You can now clearly see that at the very least you have invalid lines at lines numbers 5 and 22. I assume these are supposed to be comment lines so require a "//" at the beginning. You also have mixed capitalisation on your setters and getters.
So start by fixing those and see what happens.
1 public class student{
2 private int ID;
3 private String Name;
4
5 Student class constructor
6 student(int id, String name){
7 this.ID = id;
8 this.Name = name;
9 }
10 public int getid(){
11 return this.ID;
12 }
13 public String Getname(){
14 return this.Name;
15 }
16 public void SETid(int i){
17 this.ID = i;
18 }
19 public void sETNAme(String n){
20 this.Name=n;
21 }
22 method to display data
23 public void display() {
24 System.out.println("Student id is: " + id + " "
25 + "and Student name is: "
26 + Name;
27 );
28 System.out.println();
29 }
30 }
|
|
|
|
|
You forget to add // on commenting lines that is in line number 5 and 22
public class student{
private int ID;
private String Name;
student(int id, String name){
this.ID = id;
this.Name = name;
}
public int getid(){
return this.ID;
}
public String Getname(){
return this.Name;
}
public void SETid(int i){
this.ID = i;
}
public void sETNAme(String n){
this.Name=n;
}
public void display() {
System.out.println("Student id is: " + id + " "
+ "and Student name is: "
+ Name;
);
System.out.println();
}
}
|
|
|
|
|
See my answer of 9th June above.
|
|
|
|
|
He already did, when he cut'n'pasted it
Software rusts. Simon Stephenson, ca 1994. So does this signature. me, 2012
|
|
|
|
|
Hello. I'm new to Java -- I want to learn, and am going through HFJ. I know it's an old book, but there are no later editions, so I may be behind the times.
I'm not a professional programmer, but I'm on a few programming forums, and I can't seem to get an answer to a question I have regarding the Runnable interface. I'm in chap 15 of the book re: threading, and I came across this statement in regards to starting a new thread:
public class MyRunnable implements Runnable
Runnable threadJob = new MyRunnable ()
What I don't understand is how can you make a new object with an interface, but use the class MyRunnable. Shouldn't it be MyRunnable thread = new MyRunnable ()?
I'm just confused. Runnable isn't a class, so what's going on?
|
|
|
|
|
|
Any class can be "cast" to an interface that it implements; or it can be cast to any object it is "derived" from (e.g. "object").
In your example, a new MyRunnable is created and implicitly "down cast" to Runnable.
The interface acts like a proxy for all (different) classes that implement that interface; allowing only access to the properties / methods identified via the interface.
"Before entering on an understanding, I have meditated for a long time, and have foreseen what might happen. It is not genius which reveals to me suddenly, secretly, what I have to say or to do in a circumstance unexpected by other people; it is reflection, it is meditation." - Napoleon I
|
|
|
|
|
In C++ terms, a Java interface is a pure abstract class that only has member functions. No fields.
Fields on interfaces are always “constants”. (This is an older Java rule)
It is closer to the COM interface concept.
It could also be called an API contract.
An object can implement multiple interfaces.
This is an easy way to create delayed binding. The thread library was written decades ago, but you can create an Object today that will be usable by this old library as long as you honor the contract defined by the library. For Runnable, you must provide the run() method. The live Thread object will then invoke your run() method when you get your plumbing code correct.
|
|
|
|
|
connecting morpho biometric device with java in netbeans 8.2 and i want source code
|
|
|
|
|
Sorry, this site does not provide code to order.
|
|
|
|
|
hi am having following issue when starting kafta
confluent local services ksql-server start
The local commands are intended for a single-node development environment only,
NOT for production usage. https:
Using CONFLUENT_CURRENT: /tmp/confluent.122197
ZooKeeper is [UP]
Kafka is [UP]
Schema Registry is [UP]
Starting ksqlDB Server
Error: ksqlDB Server failed to start
kafta@kafta-VirtualBox:~$ confluent local services ksql-server log
The local commands are intended for a single-node development environment only,
NOT for production usage. https:
OpenJDK 64-Bit Server VM warning: Option UseConcMarkSweepGC was deprecated in version 9.0 and will likely be removed in a future release.
[2022-05-24 11:22:13,133] INFO KsqlConfig values:
ksql.access.validator.enable = auto
ksql.authorization.cache.expiry.time.secs = 30
ksql.authorization.cache.max.entries = 10000
ksql.cast.strings.preserve.nulls = true
ksql.connect.basic.auth.credentials.file =
ksql.connect.basic.auth.credentials.reload = false
ksql.connect.basic.auth.credentials.source = NONE
ksql.connect.error.handler = null
ksql.connect.request.headers.plugin = null
ksql.connect.url = http:
ksql.connect.worker.config =
ksql.create.or.replace.enabled = true
ksql.error.classifier.regex =
ksql.extension.dir = ext
ksql.headers.columns.enabled = true
ksql.hidden.topics = [_confluent.*, __confluent.*, _schemas, __consumer_offsets, __transaction_state, connect-configs, connect-offsets, connect-status, connect-statuses]
ksql.insert.into.values.enabled = true
ksql.internal.topic.min.insync.replicas = 1
ksql.internal.topic.replicas = 1
ksql.lambdas.enabled = true
ksql.metastore.backup.location =
ksql.metrics.extension = null
ksql.metrics.tags.custom =
ksql.nested.error.set.null = true
ksql.output.topic.name.prefix =
ksql.persistence.default.format.key = KAFKA
ksql.persistence.default.format.value = null
ksql.persistence.wrap.single.values = null
ksql.persistent.prefix = query_
ksql.properties.overrides.denylist = []
ksql.pull.queries.enable = true
ksql.query.cleanup.shutdown.timeout.ms = 30000
ksql.query.error.max.queue.size = 10
ksql.query.persistent.active.limit = 2147483647
ksql.query.persistent.max.bytes.buffering.total = -1
ksql.query.pull.consistency.token.enabled = false
ksql.query.pull.enable.standby.reads = false
ksql.query.pull.interpreter.enabled = true
ksql.query.pull.limit.clause.enabled = true
ksql.query.pull.max.allowed.offset.lag = 9223372036854775807
ksql.query.pull.max.concurrent.requests = 2147483647
ksql.query.pull.max.hourly.bandwidth.megabytes = 2147483647
ksql.query.pull.max.qps = 2147483647
ksql.query.pull.metrics.enabled = true
ksql.query.pull.range.scan.enabled = true
ksql.query.pull.router.thread.pool.size = 50
ksql.query.pull.stream.enabled = true
ksql.query.pull.table.scan.enabled = true
ksql.query.pull.thread.pool.size = 50
ksql.query.push.v2.alos.enabled = true
ksql.query.push.v2.catchup.consumer.msg.window = 50
ksql.query.push.v2.continuation.tokens.enabled = false
ksql.query.push.v2.enabled = false
ksql.query.push.v2.interpreter.enabled = true
ksql.query.push.v2.latest.reset.age.ms = 30000
ksql.query.push.v2.max.catchup.consumers = 5
ksql.query.push.v2.max.hourly.bandwidth.megabytes = 2147483647
ksql.query.push.v2.new.latest.delay.ms = 5000
ksql.query.push.v2.registry.installed = false
ksql.query.retry.backoff.initial.ms = 15000
ksql.query.retry.backoff.max.ms = 900000
ksql.query.status.running.threshold.seconds = 300
ksql.query.transient.max.bytes.buffering.total = -1
ksql.queryanonymizer.cluster_namespace = null
ksql.queryanonymizer.logs_enabled = true
ksql.readonly.topics = [_confluent.*, __confluent.*, _schemas, __consumer_offsets, __transaction_state, connect-configs, connect-offsets, connect-status, connect-statuses]
ksql.rowpartition.rowoffset.enabled = true
ksql.runtime.feature.shared.enabled = false
ksql.schema.registry.url = http:
ksql.security.extension.class = null
ksql.service.id = default_
ksql.shared.runtimes.count = 8
ksql.sink.window.change.log.additional.retention = 1000000
ksql.source.table.materialization.enabled = true
ksql.streams.shutdown.timeout.ms = 300000
ksql.suppress.buffer.size.bytes = -1
ksql.suppress.enabled = false
ksql.timestamp.throw.on.invalid = false
ksql.transient.prefix = transient_
ksql.udf.collect.metrics = false
ksql.udf.enable.security.manager = true
ksql.udfs.enabled = true
ksql.variable.substitution.enable = true
metric.reporters = []
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(io.confluent.ksql.util.KsqlConfig:376)
[2022-05-24 11:22:16,956] INFO KsqlRestConfig values:
access.control.allow.headers = []
access.control.allow.methods = []
access.control.allow.origin =
authentication.method = NONE
authentication.realm =
authentication.roles = [*]
authentication.skip.paths = []
ksql.advertised.listener = null
ksql.authentication.plugin.class = null
ksql.endpoint.logging.ignored.paths.regex =
ksql.endpoint.logging.log.queries = false
ksql.healthcheck.interval.ms = 5000
ksql.heartbeat.check.interval.ms = 200
ksql.heartbeat.discover.interval.ms = 2000
ksql.heartbeat.enable = false
ksql.heartbeat.missed.threshold.ms = 3
ksql.heartbeat.send.interval.ms = 100
ksql.heartbeat.thread.pool.size = 3
ksql.heartbeat.window.ms = 2000
ksql.idle.connection.timeout.seconds = 86400
ksql.internal.http2.max.pool.size = 3000
ksql.internal.listener = null
ksql.internal.ssl.client.authentication = NONE
ksql.lag.reporting.enable = false
ksql.lag.reporting.send.interval.ms = 5000
ksql.local.commands.location =
ksql.logging.server.rate.limited.request.paths =
ksql.logging.server.rate.limited.response.codes =
ksql.max.push.queries = 100
ksql.server.command.blocked.threshold.error.ms = 15000
ksql.server.command.response.timeout.ms = 5000
ksql.server.error.messages = class io.confluent.ksql.rest.DefaultErrorMessages
ksql.server.exception.uncaught.handler.enable = false
ksql.server.install.dir = /opt/confluent
ksql.server.preconditions = []
ksql.server.websockets.num.threads = 5
ksql.ssl.keystore.alias.external =
ksql.ssl.keystore.alias.internal =
ksql.verticle.instances = 2
ksql.worker.pool.size = 100
listeners = [http:
query.stream.disconnect.check = 1000
ssl.cipher.suites = []
ssl.client.auth = false
ssl.client.authentication = NONE
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.key.password = [hidden]
ssl.keystore.location =
ssl.keystore.password = [hidden]
ssl.keystore.reload = false
ssl.keystore.type = JKS
ssl.keystore.watch.location =
ssl.truststore.location =
ssl.truststore.password = [hidden]
ssl.truststore.type = JKS
(io.confluent.ksql.rest.server.KsqlRestConfig:376)
[2022-05-24 11:22:17,482] INFO KsqlConfig values:
ksql.access.validator.enable = auto
ksql.authorization.cache.expiry.time.secs = 30
ksql.authorization.cache.max.entries = 10000
ksql.cast.strings.preserve.nulls = true
ksql.connect.basic.auth.credentials.file =
ksql.connect.basic.auth.credentials.reload = false
ksql.connect.basic.auth.credentials.source = NONE
ksql.connect.error.handler = null
ksql.connect.request.headers.plugin = null
ksql.connect.url = http:
ksql.connect.worker.config =
ksql.create.or.replace.enabled = true
ksql.error.classifier.regex =
ksql.extension.dir = ext
ksql.headers.columns.enabled = true
ksql.hidden.topics = [_confluent.*, __confluent.*, _schemas, __consumer_offsets, __transaction_state, connect-configs, connect-offsets, connect-status, connect-statuses]
ksql.insert.into.values.enabled = true
ksql.internal.topic.min.insync.replicas = 1
ksql.internal.topic.replicas = 1
ksql.lambdas.enabled = true
ksql.metastore.backup.location =
ksql.metrics.extension = null
ksql.metrics.tags.custom =
ksql.nested.error.set.null = true
ksql.output.topic.name.prefix =
ksql.persistence.default.format.key = KAFKA
ksql.persistence.default.format.value = null
ksql.persistence.wrap.single.values = null
ksql.persistent.prefix = query_
ksql.properties.overrides.denylist = []
ksql.pull.queries.enable = true
ksql.query.cleanup.shutdown.timeout.ms = 30000
ksql.query.error.max.queue.size = 10
ksql.query.persistent.active.limit = 2147483647
ksql.query.persistent.max.bytes.buffering.total = -1
ksql.query.pull.consistency.token.enabled = false
ksql.query.pull.enable.standby.reads = false
ksql.query.pull.interpreter.enabled = true
ksql.query.pull.limit.clause.enabled = true
ksql.query.pull.max.allowed.offset.lag = 9223372036854775807
ksql.query.pull.max.concurrent.requests = 2147483647
ksql.query.pull.max.hourly.bandwidth.megabytes = 2147483647
ksql.query.pull.max.qps = 2147483647
ksql.query.pull.metrics.enabled = true
ksql.query.pull.range.scan.enabled = true
ksql.query.pull.router.thread.pool.size = 50
ksql.query.pull.stream.enabled = true
ksql.query.pull.table.scan.enabled = true
ksql.query.pull.thread.pool.size = 50
ksql.query.push.v2.alos.enabled = true
ksql.query.push.v2.catchup.consumer.msg.window = 50
ksql.query.push.v2.continuation.tokens.enabled = false
ksql.query.push.v2.enabled = false
ksql.query.push.v2.interpreter.enabled = true
ksql.query.push.v2.latest.reset.age.ms = 30000
ksql.query.push.v2.max.catchup.consumers = 5
ksql.query.push.v2.max.hourly.bandwidth.megabytes = 2147483647
ksql.query.push.v2.new.latest.delay.ms = 5000
ksql.query.push.v2.registry.installed = false
ksql.query.retry.backoff.initial.ms = 15000
ksql.query.retry.backoff.max.ms = 900000
ksql.query.status.running.threshold.seconds = 300
ksql.query.transient.max.bytes.buffering.total = -1
ksql.queryanonymizer.cluster_namespace = null
ksql.queryanonymizer.logs_enabled = true
ksql.readonly.topics = [_confluent.*, __confluent.*, _schemas, __consumer_offsets, __transaction_state, connect-configs, connect-offsets, connect-status, connect-statuses]
ksql.rowpartition.rowoffset.enabled = true
ksql.runtime.feature.shared.enabled = false
ksql.schema.registry.url = http:
ksql.security.extension.class = null
ksql.service.id = default_
ksql.shared.runtimes.count = 8
ksql.sink.window.change.log.additional.retention = 1000000
ksql.source.table.materialization.enabled = true
ksql.streams.shutdown.timeout.ms = 300000
ksql.suppress.buffer.size.bytes = -1
ksql.suppress.enabled = false
ksql.timestamp.throw.on.invalid = false
ksql.transient.prefix = transient_
ksql.udf.collect.metrics = false
ksql.udf.enable.security.manager = true
ksql.udfs.enabled = true
ksql.variable.substitution.enable = true
metric.reporters = []
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(io.confluent.ksql.util.KsqlConfig:376)
[2022-05-24 11:23:06,156] INFO JsonConverterConfig values:
converter.type = value
decimal.format = NUMERIC
schemas.cache.size = 1000
schemas.enable = false
(org.apache.kafka.connect.json.JsonConverterConfig:376)
[2022-05-24 11:23:32,941] INFO AdminClientConfig values:
bootstrap.servers = [localhost:9092]
client.dns.lookup = use_all_dns_ips
client.id =
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
host.resolver.class = class org.apache.kafka.clients.DefaultHostResolver
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:376)
[2022-05-24 11:23:35,925] WARN The configuration 'metrics.context.resource.version' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-05-24 11:23:35,926] WARN The configuration 'metrics.context.resource.commit.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:384)
[2022-05-24 11:23:36,968] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:37,068] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:37,173] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:37,173] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:37,374] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:37,374] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:37,686] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:37,686] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:38,202] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:38,206] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:39,129] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:39,436] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:40,991] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:40,991] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:42,020] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:42,024] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:43,064] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:43,064] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:43,996] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:43,997] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:45,241] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:45,242] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:46,174] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:46,175] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:47,101] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:47,102] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:48,342] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:48,343] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:49,569] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:49,569] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:50,794] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:50,899] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:51,808] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:51,809] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:52,740] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:52,740] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:53,871] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:53,872] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:54,900] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:54,901] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:55,910] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:55,911] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:57,019] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:57,019] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:58,045] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:58,046] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:23:59,282] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:23:59,282] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:00,308] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:00,309] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:01,431] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:01,431] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:02,758] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:02,758] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:03,675] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:03,676] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:04,894] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:04,894] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:06,109] INFO [AdminClient clientId=adminclient-1] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1047)
[2022-05-24 11:24:06,114] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:870)
[2022-05-24 11:24:06,140] INFO [AdminClient clientId=adminclient-1] Metadata update failed (org.apache.kafka.clients.admin.internals.AdminMetadataManager:235)
org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: fetchMetadata
[2022-05-24 11:24:06,143] ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:70)
java.lang.RuntimeException: Failed to get Kafka cluster information
at io.confluent.ksql.services.KafkaClusterUtil.getKafkaClusterId(KafkaClusterUtil.java:107)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:645)
at io.confluent.ksql.rest.server.KsqlServerMain.createExecutable(KsqlServerMain.java:162)
at io.confluent.ksql.rest.server.KsqlServerMain.main(KsqlServerMain.java:63)
Caused by: java.util.concurrent.TimeoutException
at java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180)
at io.confluent.ksql.services.KafkaClusterUtil.getKafkaClusterId(KafkaClusterUtil.java:105)
... 3 more
kafta@kafta-VirtualBox:~$
|
|
|
|
|
This has nothing to do with Java programming. The error messages are clearly identifying issues with the third party product. You should go to the KafkaSQL website for help.
|
|
|
|
|
General 
News 
Suggestion 
Question 
Bug 
Answer 
Joke 
Praise 
Rant 
Admin 
Submit an article or tip
