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 ...
| #!/usr/bin/env python3 | |
| # coding=utf-8 (for Python 2) | |
| # return: a list of lists. inner list performs intersection, outer list performs union | |
| # for example: [[1,2], [3,4]] means (1 ∩ 2) ∪ (3 ∩ 4) | |
| def union(groups, operators): | |
| if len(groups) == 1: | |
| return [groups] | |
| if len(groups) == 2 and len(operators) == 1: | |
| if operators[0] == '∪': |
| # Sample haproxy postgresql master check | |
| # | |
| # haproxy listen: 5431 | |
| # pg, instance #1 listen: 5432 (master node) | |
| # pg, instance #2 listen: 5433 (replica node) | |
| # external failover, promoting replica to master in case of failure | |
| # passwordless auth for user web | |
| # template1 database is accessible by user web | |
| # | |
| # haproxy will pass connection to postgresql master node: |
| /* MIT License | |
| * | |
| * Copyright (c) 2017 Roland Singer [[email protected]] | |
| * | |
| * Permission is hereby granted, free of charge, to any person obtaining a copy | |
| * of this software and associated documentation files (the "Software"), to deal | |
| * in the Software without restriction, including without limitation the rights | |
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | |
| * copies of the Software, and to permit persons to whom the Software is | |
| * furnished to do so, subject to the following conditions: |
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 ...
| import java.io.IOException; | |
| import java.nio.file.FileVisitResult; | |
| import java.nio.file.Files; | |
| import java.nio.file.Path; | |
| import java.nio.file.SimpleFileVisitor; | |
| import java.nio.file.attribute.BasicFileAttributes; | |
| class TempDirectory { | |
| final Path path; |