-
0 votesanswersviews
Kafka 消费者和 生产环境 者抛出错误
我尝试在Kafka-consumer中传递单词时输入错误，我输入了命令 console-1 :(对于制作人） export PATH=$PATH:/usr/hdp/current/kafka-broker/bin kafka-topics.sh --create --zookeeper ip-172-31-20-58.ec2.internal:2181 --replication-factor ... -
0 votesanswersviews
配置ACL后，Kafka Leader不可用
我已经配置了 SSL 和 SASL 安全性并尝试为Kafka主题生成数据并且没有问题地正常工作 . 但配置 Authorizer 后，即使允许授权，我也会收到以下错误 [Producer clientId = console-producer]获取具有相关ID 43的元数据时出错：（org.apache.kafka.clients.NetworkClient） 以下是主题说明 ./kafka-... -
1 votesanswersviews
向启用SSL的Kafka Broker发送消息时出错
我们已经设置了kafka实例并启用了加密 . 在尝试使用控制台消费者/ 生产环境 者连接到Kafka代理时，我们得到以下错误 org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed Caused by: javax.net.ssl.SSLProtocolException: Handshake ... -
1 votesanswersviews
在kafka中使用SSL时出错：在接收对等方的close_notify之前，入站已关闭
我尝试使用kafka-console-producer.sh发送消息时出错： client-ssl.properties: security.protocol=SSL ssl.truststore.location=client.truststore.jks ssl.truststore.password=klux$Ipzx* ssl.enabled.protocols=TLSv1.2 kafk... -
2 votesanswersviews
使用Kafka 0.8.1.1的NoReplicaOnlineException
我和一个Zookeeper和一个经纪人一起运行Kafka 0.8.1.1 . 我创建了一个分区'test2'，如下所示： /kafka-topics.sh --create --zookeeper localhost：2181 --rerelication-factor 1 --partitions 3 --topic test2 我在state-change.log中注意到了这个异常 . 这是为... -
0 votesanswersviews
kafka-console-producer.sh错误：无法找到或加载主类kafka.tools.ConsoleProducer
刚刚安装了spotify / kafka的Docker镜像 . sudo docker ps： 82c411a52a38 spotify/kafka "supervisord -n" 26 minutes ago Up 26 minutes 0.0.0.0:2181->2181/t... -
1 votesanswersviews
如何使用python将ZAP集成到jenkins？
其实我没有找到任何有用的东西 .这是link我找到了 我按照步骤..但执行python脚本时 . Traceback（最近一次调用最后一次）：文件“zap-python-script.py”，第15行，在zap.urlopen（target）文件中“/usr/lib/python2.6/site-packages/python_owasp_zap_v2.4-0.0 .2-py2.6.egg / ... -
9 votesanswersviews
kafka-python： 生产环境 者无法连接
kafka-python（1.0.0）在连接到代理时抛出错误 . 同时/ usr / bin / kafka-console-producer和/ usr / bin / kafka-console-consumer工作正常 . Python应用程序过去也运行良好，但在zookeeper重新启动后，它不再能够连接 . 我正在使用文档中的裸骨示例： from kafka import KafkaPr... -
0 votesanswersviews
不能使用kafka for python
python:2.6.6 kafka-python:1.4.3 i had run the kafka producer,but it always tips me this error: Traceback（最近一次调用最后一次）：文件“KafkaOperation.py”，第11行，来自kafka import KafkaProducer文件“/usr/lib/python2.6/site-... -
1 votesanswersviews
使用SASL_PLAINTEXT进行Kafka用户身份验证
我正在尝试在Kafka中实现安全性，以使用用户名和密码对客户端进行身份验证 . jaas配置文件配置正确 . 我首先启动zookeeper，然后只启动一个kafka节点 . 但是kafka无法从以下错误开始： [2017-08-07 13:07:08,029] INFO Registered broker 0 at path /brokers/ids/0 with addresses: EndP... -
8 votesanswersviews
我应该使用CreditCardAttribute来验证信用卡号吗？
我应该使用微软的CreditCardAttribute来验证信用卡号码吗？ [Required, CreditCard] public string CreditCardNumber { get; set; } 或者我应该让支付网关处理它，还是做其他事情？在发现一些客户无法使用他们的信用卡信息提交付款后，我问这个问题 . 幸运的是，我能够与其中一个客户合作，并发现他们的Visa卡在删除 Cred... -
3 votesanswersviews
wurstmeister kafka中的LEADER_NOT_AVAILABLE错误
我试图使用以下链接设置kafka群集 . https://github.com/wurstmeister/kafka-docker 当我尝试生成一些消息时，我得到以下错误 . [2017-09-20 17:00:53,160] WARN Error while fetching metadata with correlation id 3 : {topic=LEADER_NOT_AVAILABLE... -
3 votesanswersviews
在单个节点上使用SSL与Kafka
我希望让SSL与Kafka一起运行，以使其更安全 . 我下载了Kafka并安装了它 . 我按照关于为SSL创建证书和信任库的说明没有问题 . 我在config / server.properties中添加了以下内容 ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1 ssl.keystore.type=JKS ssl.truststore.type=JKS l... -
0 votesanswersviews
不同机器上的Kafka MultiBroker无法正常工作
我正在实施一个Kafka集群架构，在两台本地连接的机器上有2个经纪人和2个动物园管理员 Machine1（10.0.215.22）:( Hidding trival属性）Kakfa - > Server.properties port=9094 broker.id=1 num.partitions=1 zookeeper.connect=10.0.215.22:2181,10.0.229.... -
0 votesanswersviews
启动3个或更多节点后，Kafka节点连接问题
有没有人看到以下行为？ 一旦启动了第3，第4 ...... N个节点，领导节点server.log开始显示以下消息 . WARN [Controller id = 1001，targetBrokerId = 1003]无法 Build 与节点1003的连接 . 经纪可能无法使用 . （org.apache.kafka.clients.NetworkClient） WARN [Controller... -
0 votesanswersviews
Kafka发出警告未能发送SSL关闭消息
我在3个不同的服务器上有一个由3个kafka经纪人组成的kafka集群 . 让我们假设这三个服务器是 . 99.99.99.1 99.99.99.2 99.99.99.3 所有3台服务器都有一个kafka所在的共享路径 . 我创建了3个带名称的server.properties server1.properties server2.properties server3.properties ... -
2 votesanswersviews
多代理群集
我正在使用这个tutorial用于multibroker kafka集群 . 我 Build 了三个经纪人： localhost：9092 localhost：9093 localhost：9094 并使用此命令： bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --par... -
0 votesanswersviews
在使用guest虚拟机主机名称宣传Kafka侦听器后，Confluent无法启动
我正在使用一个解决方案，我在一个主机系统中将Kafka和Confluent部署在两个不同的Docker容器中 . 为了我的测试目的，我需要向Kafka提供一些测试数据 . 所以我正在修改Kafka server.configuration 以修改正在运行的docker容器中的"listeners"和"advertised.listeners"属性，如下所示... -
0 votesanswersviews
Kafka与Debezium联系
我使用'Postgresql'数据库设置环境，使用'Debezium'连接器与Kafka Connect和Kafka . Kafka有多个实例（3）正在运行，并且它配置了Zookeeper（3） . 整个管道中的连接正在工作，但是根据Debezium的文档，没有根据表中的表自动创建主题 . 数据库 . 如果是某个模式中的表A和表B，我假设在Kafka中隐式创建了2个主题 . RUNNING，连... -
0 votesanswersviews
向主题发送消息时Kafka错误
我是kafka的新手，当我尝试向主题发送消息时，我遇到了错误 . 有人可以帮我弄这个吗？ [2018-09-23 13：37：56,613] WARN [Producer clientId = console-producer]无法 Build 与节点-1的连接 . 经纪可能无法使用 . （org.apache.kafka.clients.NetworkClient） -
370 votesanswersviews
SOAP或REST for Web Services？ [关闭]
REST是一种更好的Web服务方法还是SOAP？或者它们是针对不同问题的不同工具？或者这是一个微妙的问题 - 也就是说，在某些领域比另一个稍微好一点，等等？ Bounty-Edit: 现在，差不多三年后，我想再次提出这个问题 - 提供奖励以鼓励深入回答 . 我特别感谢有关这些概念及其与PHP-universe和现代高端Web应用程序的关系的信息 . -
321 votesanswersviews
Python REST（Web服务）框架的建议？ [关闭]
是否有一个列表，其中包含不同的基于Python的REST框架的建议，以便在服务器端使用以编写自己的RESTful API？优先考虑利弊 . 请随时在此处添加推荐 . :) -
54 votesanswersviews
文件上传的REST设计[关闭]
我需要为文件上传服务创建一个REST API，允许用户： 打开一个会话 上传一堆文件 关闭会话 然后，回过头来处理他们在之前会话中上传的文件 . 为了便于处理有关每个文件的数据和处理文件本身的内容，这是我正在考虑使用的URI方案： /sessions/ /sessions/3 /sessions/3/files /sessions/3/files/5 /sessions/3/fil... -
2 votesanswersviews
一个elasticsearch / logstash实例，具有多个具有唯一索引的应用程序
我们使用swisscoms应用程序 Cloud ，目前正在评估新的Elasticsearch服务 . 我们设置它包括logstash和kibana . 我们现在为应该使用常见elasticsearch / logstash / kibana实例的每个应用添加了用户提供的服务 . 当我们第一次登录kibana时，我们看到有一个名为 logstash- 的索引，其中包含所有应用程序的所有日志 . 现在... -
83 votesanswersviews
将文件从REST Web服务发送到客户端的正确方法是什么？
我刚刚开始开发REST服务，但我遇到了一个困难的情况：从我的REST服务发送文件到我的客户端 . 到目前为止，我已经掌握了如何发送简单数据类型（字符串，整数等），但发送文件是另一回事，因为有太多的文件格式，我不知道我应该在哪里开始 . 我的REST服务是基于Java的，我使用的是Jersey，我使用JSON格式发送所有数据 . 我读过有关base64编码的内容，有人说这是一种很好的技术，有人说这不... -
0 votesanswersviews
使用c＃将zip文件作为application / json类型发布到REST endpoints
我是网络服务的新手 . 我正在尝试将zip文件上传到REST服务，其内容类型和接受标头值为“application / json”（由Web服务指定） 我无法上传文件，因为它正在抛出“远程服务器返回错误：（400）错误请求” . 我尝试传递multipart \ form-data，但它抛出了同样的异常 . 另外，我很困惑，因为我听说对于zip文件我们需要使用“Multipart / form-d... -
2 votesanswersviews
Oracle示例数据问题
所以，我有这个基于java的数据转换/屏蔽工具，我想在Oracle 10g上进行测试 . Oracle 10g的优点在于，您可以获得大量样本模式，其中包含50万条记录 . 模式是：SH，OE，HR，IX等 . 所以，我安装了10g，发现安装脚本在ORACLE_HOME / demo / scripts下 . 我稍微定制了这些脚本以便在批处理模式下运行 . 这解决了我的一半要求 - 为我的数据转换... -
0 votesanswersviews
如何验证上传的文件是否完整
我有一个系统，用户可以通过FTP服务器或html表单上传CSV文件 . 在我的最后，脚本轮询uploads目录并处理找到的新文件 . 一些用户将通过从Excel导出CSV来创建CSV，而其他用户将使用他们自己的脚本以编程方式创建CSV . 我现在关注的是：我怎样才能100％确定我的处理脚本所处理的文件是否完整 - 换句话说它不是部分文件（正在进行，上传失败等）？ 如果文件格式是更结构化的，比如XM... -
1 votesanswersviews
Rails CSV db population
我有这个场景，我需要一些设计建议，可能是一个小结构定义： 我有一个用户可以上传一个csv文件，并根据该文件的内容我必须填充数据库，听起来简单呃！ 好到目前为止一切都那么好，现在问题是这个csv非常大，我的意思是它有大约100个 Headers 字段（听起来很疯狂），谁知道每个文件有多少条记录，但无论如何，到目前为止我们有这个csv上传和db人口 . 但是等等，这个csv文件需要根据字段（“DIVI... -
2 votesanswersviews
Web API帮助示例 - C＃
ASP.NET Web API可以轻松安装带有样本生成器的Nuget帮助页面 . 它's easy to get it to generate and display sample requests, but not so easy it seems to get it to display sample responses (httpsampleresponses) so that when d...