小编Iva*_*cki的帖子

只问一个愚蠢的问题,希望有人能回答这个问题.

关于MQTT经纪人,我有点困惑.基本上,令人困惑的是,有很多东西被用于数据存储,传输和处理(如Flume,HDInsight,Spark等).那么,何时以及为什么我需要使用一个MQTT代理？

如果我想在HiveMQ中使用Windows 10 IoT应用程序,我可以从哪里获取详细信息？如何使用它？我如何从这个MQTT经纪人那里获益？我是否可以不使用Azure或HDFS直接从我的IoT应用程序发送数据？那么,MQTT经纪人如何融入其中或帮助我实现某些目标呢？

我是所有这些的新手,并试图找到一些教程,但是,我没有得到任何正确的.请详细解释一下,或者为此提供一些教程？

当我们使用kubeadm来设置k8s集群时,有两个配置选项:

--pod-network-cidr

--service-cidr (默认'10 .96.0.0/12')

问题是:

1. 如果我用10.244.0.0./12了pod-network-cidr,我是否需要保存Kubernetes该IP地址范围？如果我们已经开始10.244.0.0/12用于其他机器会发生什么.

2. 我可以设置service-cidr和pod-network-cidr相同的范围吗？我不明白是怎么service-cidr运作的.

我有 Spring Boot 应用程序，它通过@JmsListener组件类中的注释监听 IBM MQ 队列，如下所示。MQ 属性（主机名、通道、端口等）是从yaml文件设置的。

 @JmsListener(destination = "<QueueName>")
 public void receiveMessage(BytesMessage msg) { 
     //snippet to read msg
 }

MQ 依赖项添加到 gradle 构建中，如下所示，

compile("com.ibm.mq:mq-jms-spring-boot-starter:0.0.2") {  
        exclude group: 'org.springframework.boot', module: 'spring-boot-starter-logging'
    }

只要我使用 Tomcat 容器在本地运行应用程序，就可以正常工作并监听消息。但是，如果我将其打包为 EAR 并部署到 Wesbphere8.5 服务器，它会抛出以下异常，并且侦听器不会从队列中读取消息。我确认所有运行时依赖项都打包在 EAR 中。尝试使用不同版本的 MQ 依赖项，但没有成功。

2018-07-10 15:21:16,531 错误 DefaultMessageListenerContainer - 无法刷新目标“QueueName”的 JMS 连接 - 使用 FixBackOff{interval=5000, currentAttempts=34, maxAttempts=unlimited} 重试。原因：JMSFMQ6312：Java(tm) MQI 中发生异常。嵌套异常是 com.ibm.mq.jmqi.JmqiException: CC=2;RC=2195;AMQ9546: 收到错误返回代码。[1=java.lang.reflect.InitationTargetException[null],3=NativeConstructorAccessorImpl.newInstance0]

需要帮助来解决此问题。

我正在构建一些Spring Boot微服务，这些服务将部署在Kubernetes（专用于AKS）集群中。我正计划将活动性和就绪性检查的probePath设置为同时指向执行器运行状况端点，但我想知道这是否不是最佳选择。我最初的想法是，检查路径将很有用（至少对于就绪状态而言），以便在Spring启动并能够处理请求之前，不向其发送流量。由于这些服务使用数据库连接，并且如果执行器运行状况指示器无法建立连接，则执行器运行状况指示器将报告状态为关闭，这不是一个好主意吗？

考虑到活动性，我认为它可能会一遍又一遍地回收豆荚/容器，即使（在数据库关闭的情况下）它可能无法解决任何问题。

准备就绪后，我认为如果数据库关闭，这可能会导致可用应用程序池为0。如果数据库关闭，该应用程序本身很有可能不是很有用，但是我认为某些部件可能仍然可以工作。

对于这种事情是否有建议的最佳实践？

据我了解，全局外部地址用于外部负载均衡器，而区域外部地址用于虚拟机和区域负载均衡器。为什么全球知识产权和区域知识产权之间存在如此大的分离？

他们都可以通过互联网联系到。有实施细节吗？有人可以解释一下吗？

当我发出消息时,我想从经纪人那里得到一些回应.我已经尝试过使用的CallBack机制(通过实现CallBack),KafkaProducer.send但它没有工作,也没有调用onCompletion方法.

当我关闭Kafka服务器并尝试生成消息时,它会调用回调方法.

有没有其他方式得到确认？

@Override
    public void onCompletion(RecordMetadata metadata, Exception exception) {
        long elapsedTime = System.currentTimeMillis() - startTime;
        System.out.println("Called Callback method");
        if (metadata != null) {
            System.out.println("message(" + key + ", " + message
                    + ") sent to partition(" + metadata.partition() + "), "
                    + "offset(" + metadata.offset() + ") in " + elapsedTime
                    + " ms");
        } else {
            exception.printStackTrace();
        }

    }

props.put("bootstrap.servers", "localhost:9092");
props.put("client.id", "mytopic");
props.put("key.serializer", org.apache.kafka.common.serialization.StringSerializer.class);
props.put("value.serializer", org.apache.kafka.common.serialization.ByteArraySerializer.class);

KafkaProducer<String, byte[]> producer = new KafkaProducer<String,byte[]>(props); …

我检查了我的服务器日志，有很多错误，例如：

S3::putBucket(******): [BucketAlreadyOwnedByYou] Your previous request to create the named bucket succeeded and you already own it. in /var/www/html/****/public_html/*****/common/config/S3.php on line 188

我用谷歌搜索了它，但我没有得到任何适当的帮助，谁能告诉我是什么导致了这个错误？我该如何解决这个问题？

因为Prometheus仅支持json中的文本度量和许多工具返回指标(如Finatra,Spring Boot),所以我创建了一个将json转换为文本的简单代理.因为我想将它用于多个源,所以通过查询参数设置要从中检索实际度量的目标.

指标网址如下所示:/metrics?prefix=finatra&url=http:// :9990/admin/metrics.json

这在浏览器或卷曲中工作正常.但是,在普罗米修斯的'？' 被编码为'%3F',因此请求失败:/metrics%3Fprefix=finatra&url=http:// :9990/admin/metrics.json

如何防止Prometheus编码'？'？这是普罗米修斯的错误吗？我已经尝试用'%'或'\'来逃避,使用unicode等,但仍然没有运气.

我在JBoss论坛上复制了以下问题.我们面临同样的问题.

这是我的场景:

我只有一个DIST_SYNC缓存,集群中的大多数JVM都配置了capacityFactor = 0(类似于distibutedlocalstorage=falseCoherence 的属性),并且某些节点配置了capacityFactor>0(例如1000).我们谈论的是100个节点和capacityFactor=0另外4个节点,其中集群是一个单独的"站点/机架".分区处理已关闭,numOwners为1.

当所有节点capacityFactor > 0都关闭时,群集将进入降级状态,如果没有完整的群集重新启动,它将无法再恢复.

如果我启用分区处理,那么可以抛出有效的异常,我认为是预期的行为(Infinispan用户指南).

我认为这是问题,这是一个错误:

14/11/17 09:27:25 WARN topology.CacheTopologyControlCommand:ISPN000071:处理命令时遇到异常CacheTopologyControlCommand {cache = shared,type = JOIN,sender = testserver1 @ xxxxxxx-22311,site-id = xxx,rack-id = xxx,machine-id = 24字节,joinInfo = CacheJoinInfo {consistentHashFactory =org.infinispan.distribution.ch.impl.TopologyAwareConsistentHashFactory@78b791ef,hashFunction = MurmurHash3,numSegments = 60,numOwners = 1,timeout = 120000,totalOrder = false,distributed = true},topologyId = 0,rebalanceId = 0,currentCH = null,pendingCH = null,availabilityMode = null,throwable = null,viewId = 3}

java.lang.IllegalArgumentException:缓存拓扑的挂起一致性哈希必须包含所有当前一致哈希的成员

    at org.infinispan.topology.CacheTopology.<init>(CacheTopology.java:48)

    at org.infinispan.topology.CacheTopology.<init>(CacheTopology.java:43)

    at org.infinispan.topology.ClusterCacheStatus.startQueuedRebalance(ClusterCacheStatus.java:631)

    at org.infinispan.topology.ClusterCacheStatus.queueRebalance(ClusterCacheStatus.java:85)

    at …

尽管resourceQuotas可能会限制名称空间中configmap的数量，但是是否有任何这样的选项来限制单个configmap的大小？我不希望某些用户开始将大型文本文件作为configmaps上传。

ConfigMap etcd支持的最大大小是多少？如果etcd方面有合理的限制，那就应该没问题。