bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...
bin/kafka-topics.sh --zookeeper localhost:2181 --list
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --config retention.ms=1000
... wait a minute ...
$ uname -r
| import org.apache.mina.filter.ssl.SslFilter; | |
| import org.apache.mina.transport.socket.nio.NioSocketConnector; | |
| public class TunnelClient{ | |
| ....... | |
| NioSocketConnector nioConnector = new NioSocketConnector(1); | |
| nioConnector.setDefaultRemoteAddress(tunnelServerAddress); | |
| nioConnector.setHandler(handler); | |
| SslFilter sslFilter = new SslFilter(getSSLContext()); |
| // Package main | |
| // Copyright 2017 Kranz. All rights reserved. | |
| // Use of this source code is governed by a MIT-style | |
| // license that can be found in the LICENSE file. | |
| /** | |
| Test read file by chunks | |
| ➜ read ll | |
| total 13241936 | |
| drwxr-xr-x 5 rlopes staff 170B 16 Jan 01:19 ./ |