我有一个简单的类来消费来自kafka服务器的消息.大多数代码都是从org.apache.kafka.clients.consumer.KafkaConsumer.java的注释中复制的.
public class Demo {
public static void main(String[] args) {
Properties props = new Properties();
props.put("metadata.broker.list", "192.168.144.10:29092");
props.put("group.id", "test");
props.put("session.timeout.ms", "1000");
props.put("enable.auto.commit", "true");
props.put("auto.commit.interval.ms", "10000");
KafkaConsumer<byte[], byte[]> consumer = new KafkaConsumer<byte[], byte[]>(props);
consumer.subscribe("voltdbexportAUDIT", "voltdbexportTEST");
boolean isRunning = true;
while (isRunning) {
Map<String, ConsumerRecords<byte[], byte[]>> records = consumer.poll(100);
process(records);
}
consumer.close();
}
private static Map<TopicPartition, Long> process(Map<String, ConsumerRecords<byte[], byte[]>> records) {
Map<TopicPartition, Long> processedOffsets = new HashMap<>();
for (Map.Entry<String, ConsumerRecords<byte[], byte[]>> recordMetadata : records.entrySet()) {
List<ConsumerRecord<byte[], byte[]>> recordsPerTopic = recordMetadata.getValue().records(); …在gcloud中有一个k8s集群，其中运行一些http应用程序。
用于从本地主机进行远程呈现调试，没有问题。
但今天总是遇到代理install time out错误。
kubectl 到集群，没问题。
telepresence connect
Launching Telepresence Root Daemon
Need root privileges to run: /usr/local/bin/telepresence daemon-foreground /Users/xxx/Library/Logs/telepresence '/Users/xxx/Library/Application Support/telepresence' ''
Password:
Launching Telepresence User Daemon
Connected to context my-cluster (https://xx.xxx.xxx.x)
telepresence intercept xxx-service --env-json /tmp/xxx-service.json
telepresence: error: Intercept: Failed to establish intercept: the agent install timed out. The current timeout 2m0s can be configured as "timeouts.agentInstall" in "/Users/xxx/Library/Application Support/telepresence/config.yml"
远程呈现的一些日志
2021/09/01 12:24:04.4264 info connector : --- (from pkg/client/connector/command.go:329)
2021/09/01 12:24:04.4272 info connector : Telepresence …