Click here to Skip to main content
15,880,796 members
Home / Discussions / Java
   

Java

 
AnswerRe: solve the error Pin
Richard MacCutchan8-Jun-22 22:56
mveRichard MacCutchan8-Jun-22 22:56 
AnswerRe: solve the error Pin
Sakshi Jain 202226-Jun-22 20:59
Sakshi Jain 202226-Jun-22 20:59 
GeneralRe: solve the error Pin
Richard MacCutchan26-Jun-22 21:41
mveRichard MacCutchan26-Jun-22 21:41 
GeneralRe: solve the error Pin
Peter_in_278026-Jun-22 22:19
professionalPeter_in_278026-Jun-22 22:19 
QuestionRunnable as a new object? Pin
Member 156629325-Jun-22 13:24
Member 156629325-Jun-22 13:24 
AnswerRe: Runnable as a new object? Pin
Richard MacCutchan5-Jun-22 21:27
mveRichard MacCutchan5-Jun-22 21:27 
AnswerRe: Runnable as a new object? Pin
Gerry Schmitz6-Jun-22 13:47
mveGerry Schmitz6-Jun-22 13:47 
AnswerRe: Runnable as a new object? Pin
englebart7-Jul-22 16:10
professionalenglebart7-Jul-22 16:10 
QuestionConnect morpho biometric device with jav Pin
Member 156609363-Jun-22 3:10
Member 156609363-Jun-22 3:10 
AnswerRe: Connect morpho biometric device with jav Pin
Richard MacCutchan3-Jun-22 9:06
mveRichard MacCutchan3-Jun-22 9:06 
Questionissue starting my ksql-server Pin
james michael May202225-May-22 13:20
james michael May202225-May-22 13:20 
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://docs.confluent.io/current/cli/index.html

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://docs.confluent.io/current/cli/index.html

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://localhost:8083
        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://localhost:8081
        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://0.0.0.0:8088]
        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://localhost:8083
        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://localhost:8081
        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:~$

AnswerRe: issue starting my ksql-server Pin
Richard MacCutchan25-May-22 22:03
mveRichard MacCutchan25-May-22 22:03 
QuestionHash Table implementation Pin
Member 156289598-May-22 18:52
Member 156289598-May-22 18:52 
AnswerRe: Hash Table implementation Pin
Richard Deeming8-May-22 21:27
mveRichard Deeming8-May-22 21:27 
AnswerRe: Hash Table implementation Pin
Richard MacCutchan8-May-22 21:43
mveRichard MacCutchan8-May-22 21:43 
QuestionHi guys my code is not compiling as its showing cannot find symbol please help Pin
Member 1561125322-Apr-22 4:48
Member 1561125322-Apr-22 4:48 
AnswerRe: Hi guys my code is not compiling as its showing cannot find symbol please help Pin
Dave Kreskowiak22-Apr-22 4:53
mveDave Kreskowiak22-Apr-22 4:53 
AnswerRe: Hi guys my code is not compiling as its showing cannot find symbol please help Pin
zemiak1231-May-22 13:06
zemiak1231-May-22 13:06 
QuestionDevelopment of Wiki functionality in JSF project Pin
Dev Learning22-Apr-22 2:25
Dev Learning22-Apr-22 2:25 
QuestionRelated to resolve my error(Rearranging an array) Pin
Prateek Bajpai10-Apr-22 4:49
Prateek Bajpai10-Apr-22 4:49 
AnswerRe: Related to resolve my error(Rearranging an array) Pin
Richard MacCutchan10-Apr-22 5:53
mveRichard MacCutchan10-Apr-22 5:53 
QuestionHOW TO USE JTABLE TO DISPLAY ALL RECORDS DATA FROM DATABASE USING JDBC Pin
Member 1558267928-Mar-22 21:48
Member 1558267928-Mar-22 21:48 
AnswerRe: HOW TO USE JTABLE TO DISPLAY ALL RECORDS DATA FROM DATABASE USING JDBC Pin
Richard MacCutchan29-Mar-22 1:31
mveRichard MacCutchan29-Mar-22 1:31 
GeneralRe: HOW TO USE JTABLE TO DISPLAY ALL RECORDS DATA FROM DATABASE USING JDBC Pin
Member 155826795-Apr-22 21:49
Member 155826795-Apr-22 21:49 
QuestionWhiteSpace Character Pin
Sudhanshu_India5-Mar-22 23:26
Sudhanshu_India5-Mar-22 23:26 

General General    News News    Suggestion Suggestion    Question Question    Bug Bug    Answer Answer    Joke Joke    Praise Praise    Rant Rant    Admin Admin   

Use Ctrl+Left/Right to switch messages, Ctrl+Up/Down to switch threads, Ctrl+Shift+Left/Right to switch pages.