Stephane Maarek

Results 58 comments of Stephane Maarek

Just read the log... It says it isn't initialized, then it goes and initialize it..... ``` Creating admin client with broker list : 10.138.36.42:9092,10.138.175.56:9092,10.138.38.157:9092,10.138.185.249:9092,10.138.98.67:9092,10.138.85.13:9092 ```

@xiaochuanyu I did something similar here: https://github.com/Yelp/kafka-utils/pull/138/files It may be worth refactoring your code and isolate the ssh client construction method for all the other components to benefit from it

or set up correctly your `~/.ssh/config`

Thanks! > As for your second point, yes I definitely want to get executables added for Windows and Linux (there is an executable for macos already here. This is not...

See https://github.com/saturnism/grpc-java-by-example/tree/master/error-handling-example/error-server/src/main/java/com/example/grpc/server Maybe you could get inspired / get a PR from the author

@bringhurst have you seen https://github.com/linkedin/kafka-tools/pull/51 ?

confused about the CI failures, let me know if you see anything wrong

More suggestions: - Kafka 0.10.1 has now the ability to map timestamps to offsets, (see offsetForTimes at https://kafka.apache.org/0101/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html). It maps nicely to a where query with a "kafka_timestamp" and would...