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 ./ |