cp-docker-images
cp-docker-images copied to clipboard
confluentinc
Kafka rest problem
I deployed kafka, zookeeper, kafka-rest on open shift. Kafka-rest is not responding curl -vvv 127.0.0.1:8089/topics --output -
- Trying 127.0.0.1...
- TCP_NODELAY set
- Connected to 127.0.0.1 (127.0.0.1) port 8089 (#0)
GET /topics HTTP/1.1 Host: 127.0.0.1:8089 User-Agent: curl/7.64.1 Accept: /
- Closing connection 0 P%
could you guys help me what am I doing wrong?
`
[main] INFO org.apache.kafka.clients.admin.AdminClientConfig - AdminClientConfig values:
| bootstrap.servers = [PLAINTEXT://kafka:9092] | client.dns.lookup = default | client.id = | connections.max.idle.ms = 300000 | 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 = 120000 | retries = 5 | 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.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.mechanism = GSSAPI | security.protocol = PLAINTEXT | security.providers = null | send.buffer.bytes = 131072 | ssl.cipher.suites = null | ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] | ssl.endpoint.identification.algorithm = https | ssl.key.password = null | ssl.keymanager.algorithm = SunX509 | ssl.keystore.location = null | ssl.keystore.password = null | ssl.keystore.type = JKS | ssl.protocol = TLS | ssl.provider = null | ssl.secure.random.implementation = null | ssl.trustmanager.algorithm = PKIX | ssl.truststore.location = null | ssl.truststore.password = null | ssl.truststore.type = JKS | | [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 5.4.2-ccs | [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 444e12d6acc76f91 | [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1591017402841 | ===> Launching ... | ===> Launching kafka-rest ... | [2020-06-01 13:16:51,940] INFO KafkaRestConfig values: | access.control.allow.headers = | access.control.allow.methods = | access.control.allow.origin = | authentication.method = NONE | authentication.realm = | authentication.roles = [*] | authentication.skip.paths = [] | bootstrap.servers = PLAINTEXT://kafka:9092 | client.init.timeout.ms = 60000 | client.sasl.kerberos.kinit.cmd = /usr/bin/kinit | client.sasl.kerberos.min.time.before.relogin = 60000 | client.sasl.kerberos.service.name = | client.sasl.kerberos.ticket.renew.jitter = 0.05 | client.sasl.kerberos.ticket.renew.window.factor = 0.8 | client.sasl.mechanism = GSSAPI | client.security.protocol = PLAINTEXT | client.ssl.cipher.suites = | client.ssl.enabled.protocols = TLSv1.2,TLSv1.1,TLSv1 | client.ssl.endpoint.identification.algorithm = | client.ssl.key.password = [hidden] | client.ssl.keymanager.algorithm = SunX509 | client.ssl.keystore.location = | client.ssl.keystore.password = [hidden] | client.ssl.keystore.type = JKS | client.ssl.protocol = TLS | client.ssl.provider = | client.ssl.trustmanager.algorithm = PKIX | client.ssl.truststore.location = | client.ssl.truststore.password = [hidden] | client.ssl.truststore.type = JKS | client.timeout.ms = 500 | client.zk.session.timeout.ms = 30000 | compression.enable = true | consumer.instance.timeout.ms = 300000 | consumer.iterator.backoff.ms = 50 | consumer.iterator.timeout.ms = 1 | consumer.request.max.bytes = 67108864 | consumer.request.timeout.ms = 1000 | consumer.threads = 50 | debug = false | fetch.min.bytes = -1 | host.name = cp-kafka-rest | id = rest_proxy_1 | idle.timeout.ms = 30000 | kafka.rest.resource.extension.class = [] | listeners = [https://0.0.0.0:8082 ] | metric.reporters = [] | metrics.jmx.prefix = kafka.rest | metrics.num.samples = 2 | metrics.sample.window.ms = 30000 | metrics.tag.map = [] | port = 8082 | producer.threads = 5 | request.logger.name = io.confluent.rest-utils.requests | resource.extension.classes = [] | response.mediatype.default = application/vnd.kafka.v1+json | response.mediatype.preferred = [application/vnd.kafka.v1+json, application/vnd.kafka+json, application/json] | rest.servlet.initializor.classes = [] | schema.registry.url = http://localhost:8081 | shutdown.graceful.ms = 1000 | simpleconsumer.pool.size.max = 25 | simpleconsumer.pool.timeout.ms = 1000 | ssl.cipher.suites = [] | ssl.client.auth = false | ssl.client.authentication = NONE | ssl.enabled.protocols = [] | ssl.endpoint.identification.algorithm = null | ssl.key.password = [hidden] | ssl.keymanager.algorithm = | ssl.keystore.location = | ssl.keystore.password = [hidden] | ssl.keystore.type = JKS | ssl.protocol = TLS | ssl.provider = | ssl.trustmanager.algorithm = | ssl.truststore.location = | ssl.truststore.password = [hidden] | ssl.truststore.type = JKS | websocket.path.prefix = /ws | websocket.servlet.initializor.classes = [] | zookeeper.connect = | (io.confluent.kafkarest.KafkaRestConfig) | [2020-06-01 13:16:52,536] INFO Logging initialized @5797ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) | [2020-06-01 13:16:53,737] INFO Adding listener: https://0.0.0.0:8082 (io.confluent.rest.ApplicationServer) | [2020-06-01 13:16:57,836] INFO Registered kafka:type=kafka.Log4jController MBean (io.confluent.kafka.utils.Log4jControllerRegistration$) | [2020-06-01 13:17:00,534] INFO Verifying properties (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,843] WARN Property bootstrap.servers is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,843] WARN Property client.security.protocol is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,844] INFO Property group.id is overridden to (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,844] WARN Property host.name is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,844] WARN Property id is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,844] WARN Property listeners is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,844] WARN Property producer.client.id is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,845] INFO Property zookeeper.connect is overridden to (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:00,845] WARN Property zookeeper.host is not valid (io.confluent.kafka.utils.VerifiableProperties) | [2020-06-01 13:17:01,042] INFO KafkaAvroDeserializerConfig values: | bearer.auth.token = [hidden] | schema.registry.ssl.truststore.type = JKS | schema.reflection = false | auto.register.schemas = true | basic.auth.credentials.source = URL | schema.registry.ssl.keystore.password = [hidden] | schema.registry.ssl.provider = | schema.registry.ssl.endpoint.identification.algorithm = https | schema.registry.ssl.truststore.location = | specific.avro.reader = false | value.subject.name.strategy = class io.confluent.kafka.shaded.serializers.subject.TopicNameStrategy | schema.registry.url = [http://localhost:8081 ] | schema.registry.ssl.keystore.location = | schema.registry.ssl.trustmanager.algorithm = PKIX | schema.registry.ssl.key.password = [hidden] | schema.registry.ssl.keystore.type = JKS | proxy.port = -1 | schema.registry.ssl.secure.random.implementation = | schema.registry.ssl.cipher.suites = [] | max.schemas.per.subject = 1000 | schema.registry.ssl.truststore.password = [hidden] | basic.auth.user.info = [hidden] | proxy.host = | schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] | schema.registry.ssl.protocol = TLS | schema.registry.basic.auth.user.info = [hidden] | bearer.auth.credentials.source = STATIC_TOKEN | schema.registry.ssl.keymanager.algorithm = SunX509 | key.subject.name.strategy = class io.confluent.kafka.shaded.serializers.subject.TopicNameStrategy | (io.confluent.kafka.shaded.serializers.KafkaAvroDeserializerConfig) | [2020-06-01 13:17:01,244] INFO KafkaJsonDecoderConfig values: | json.fail.unknown.properties = true | (io.confluent.kafka.shaded.serializers.KafkaJsonDecoderConfig) | [2020-06-01 13:17:03,838] INFO jetty-9.4.20.v20190813; built: 2019-08-13T21:28:18.144Z; git: 84700530e645e812b336747464d6fbbf370c9a20; jvm 1.8.0_212-b04 (org.eclipse.jetty.server.Server) | [2020-06-01 13:17:04,445] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) | [2020-06-01 13:17:04,533] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) | [2020-06-01 13:17:04,536] INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session) | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.ConsumersResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.ConsumersResource will be ignored. | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.v2.ConsumersResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.v2.ConsumersResource will be ignored. | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.BrokersResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.BrokersResource will be ignored. | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.v2.PartitionsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.v2.PartitionsResource will be ignored. | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.PartitionsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.PartitionsResource will be ignored. | Jun 01, 2020 1:17:10 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime | WARNING: A provider io.confluent.kafkarest.resources.TopicsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider io.confluent.kafkarest.resources.TopicsResource will be ignored. | [2020-06-01 13:17:13,147] INFO HV000001: Hibernate Validator 6.0.11.Final (org.hibernate.validator.internal.util.Version) | [2020-06-01 13:17:18,837] INFO JVM Runtime does not support Modules (org.eclipse.jetty.util.TypeUtil) | [2020-06-01 13:17:18,838] INFO Started o.e.j.s.ServletContextHandler@632ceb35{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) | [2020-06-01 13:17:19,234] INFO Started o.e.j.s.ServletContextHandler@512baff6{/ws,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) | [2020-06-01 13:17:21,344] INFO Started NetworkTrafficServerConnector@5fcd892a{SSL,[ssl, http/1.1]}{0.0.0.0:8082} (org.eclipse.jetty.server.AbstractConnector) | [2020-06-01 13:17:21,345] INFO Started @34707ms (org.eclipse.jetty.server.Server) | [2020-06-01 13:17:21,345] INFO Server started, listening for requests... (io.confluent.kafkarest.KafkaRestMain)
`
