Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Running 'ksql-cli local' on different kafka port from default #334

Closed
geojub opened this issue Oct 3, 2017 · 3 comments
Closed

Running 'ksql-cli local' on different kafka port from default #334

geojub opened this issue Oct 3, 2017 · 3 comments

Comments

@geojub
Copy link

geojub commented Oct 3, 2017

Hi all,

I'm trying to run 'ksql-cli local' using another kafka server instance which runs on a different port than the default one (port 10092) and is not working.

Everytime when ksql-cli starts it uses the default port for the bootstrap.server (TCP:9092), even that in the config file I set another port (TCP:10092).

The setting was made after the ksql compilation and also before the compilation and in the both cases the result was the same.

The contents of the ksqlserver.properties config file:

cat config/ksqlserver.properties

bootstrap.servers=localhost:10092
application.id=ksql_server_quickstart
ksql.command.topic.suffix=commands

listeners=http://localhost:8080

The output of ./bin/ksql-run-class io.confluent.ksql.Ksql "local":

(io.confluent.ksql.util.KsqlConfig:223)
[2017-10-03 17:30:22,204] INFO KsqlConfig values:
        application.id = ksql_
        application.server =
        bootstrap.servers = [localhost:9092]
        buffered.records.per.partition = 1000
        cache.max.bytes.buffering = 10000000
        client.id =
        commit.interval.ms = 2000
        connections.max.idle.ms = 540000
        default.key.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde
        default.timestamp.extractor = class org.apache.kafka.streams.processor.FailOnInvalidTimestamp
        default.value.serde = class org.apache.kafka.common.serialization.Serdes$ByteArraySerde
        key.serde = null
        metadata.max.age.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        num.standby.replicas = 0
        num.stream.threads = 4
        partition.grouper = class org.apache.kafka.streams.processor.DefaultPartitionGrouper
        poll.ms = 100
        processing.guarantee = at_least_once
        receive.buffer.bytes = 32768
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        replication.factor = 1
        request.timeout.ms = 40000
        retry.backoff.ms = 100
        rocksdb.config.setter = null
        security.protocol = PLAINTEXT
        send.buffer.bytes = 131072
        state.cleanup.delay.ms = 600000
        state.dir = /tmp/kafka-streams
        timestamp.extractor = null
        value.serde = null
        windowstore.changelog.additional.retention.ms = 86400000
        zookeeper.connect =
@bluemonk3y
Copy link

bluemonk3y commented Oct 3, 2017

Hi @geojub you should be able to run it using:

bin/ksql-cli local --properties-file=config/ksqlserver.properties

@geojub
Copy link
Author

geojub commented Oct 3, 2017

Thank you!

@miguno
Copy link
Contributor

miguno commented Oct 5, 2017

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants