我正在尝试配置一个kafka客户端，以针对安全的kafkaserver进行身份验证。我已经设置了jaas和ssl配置，但它抱怨serviceNames。
我没有使用Kerberos。
命令
KAFKA_OPTS="-Djava.security.auth.login.config=./jaas.conf" \
kafka-console-producer --broker-list k0:9092,k1:9092,k2:9092 \
--topic test-topic
--producer.config ./ssl.properties
错误
org.apac
浏览 1384提问于2019-03-05得票数 6
回答已采纳
我有一个spring引导/spring应用程序，它在作为war文件部署到外部tomcat服务器时正确地使用消息，我将java.security.auth.login.config环境变量设置为具有用户名和密码的client_jaas.conf文件，如下所示。现在，我试图将同一个应用程序部署到本地Docker容器中，就像jar一样，jar使用内部tomcat服务器，据我所知，它似乎没有连接到Kafka代理，据我所知，它找不到client_jaas.conf文件。有没有办法让client_jaas.conf配置在application.properties文件中，或者提到用户名、密码等，这样我就可
浏览 9提问于2020-07-04得票数 0
1回答
我已经设法在Docker中使用Web Tracker、Scala Stream Kafka Collector、Stream Enrich、Druid和Metabase实现了端到端的本地实现。
在使用Helm在Kubernetes中构建工作的登台环境之前，我想尝试将Scala Stream Kafka收集器连接到我们的Kafka Confluent Cloud帐户。但是，我遇到了SASL身份验证的问题。关于这个主题的文档非常少，只是让我们参考了Kafka文档。这是我的config.hocon配置-
sink {
enabled = kafka
brokers = "our-do
浏览 101提问于2021-03-10得票数 0
我正在尝试在启用SSL的Kafka集群中注册一个MySql Debezium连接器。我所使用的卷发是：
curl -k -X POST -H "Accept:application/json" -H "Content-Type:application/json" https://<IPADDRESS>:8083/connectors/ -d '{ "name": "test-eds-extactor-profile", "config": { "connector.class"
浏览 0提问于2019-07-18得票数 2
回答已采纳
我正在使用Flink 1.8试图连接到Kerberized经纪人。
我将KafkaClient条目设置为jaas.conf，如下所示：
KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useTicketCache=true
renewTicket=true
serviceName="kafka";
};
Client {
com.sun.security.auth.module.Krb5LoginModule required
useTicke
浏览 0提问于2019-09-16得票数 1
我希望创建并使用java实用程序来获取信息和创建/修改/删除主题。
要创建实用程序，我正在尝试来自的示例
以下是我如何在代码中设置属性：
Properties adminConfig = new Properties();
adminConfig.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "server1:9092,server2:9092,server3:9092");
adminConfig.put("security.protocol", "SASL_SSL");
adminConfig
浏览 10提问于2021-02-16得票数 1
回答已采纳
我有java类实现可运行的，并在bluemix中实例化kafka使用者。当试图实例化KafkaConsumer时，该类将抛出异常以下。jaas.conf文件存储在共享目录中。在过去的一个月里，这一切都很顺利。它今天就开始抛出这个错误。我不记得对我的代码做过任何更改。我正在使用kafka-client 0.9.0.0。我也尝试了卡夫卡客户0.9.0.1与相同的结果。
org.apache.kafka.common.KafkaException:
java.lang.IllegalArgumentException: Could not find a
'KafkaClient'
浏览 4提问于2016-03-24得票数 1
回答已采纳
5回答
在kafka文档中，它说主体是kafka/hostname@EXAMPLE.COM，所以sasl.kerberos.service.name应该是kafka，但我非常困惑kafka代理配置说： 代表 "The Kerberos principal name that Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's config." 为什么我们需要设置这个配置： ，它是如何工作的？为什么kafka运行的Kerberos主体名称是“ “非” “
浏览 201提问于2017-03-02得票数 3
回答已采纳
我正在使用这个舵图：
而这些覆盖在values.yaml中
configurationOverrides:
advertised.listeners: |-
EXTERNAL://kafka-${KAFKA_BROKER_ID}.host-removed:$((31090 + ${KAFKA_BROKER_ID}))
listener.security.protocol.map: |-
PLAINTEXT:SASL_PLAINTEXT,EXTERNAL:SASL_PLAINTEXT
sasl.enabled.mechanisms: SCRAM-SHA-256
a
浏览 1提问于2018-09-13得票数 4
回答已采纳
我有一个Kafka生产者web应用程序托管在IBM Websphere Liberty Core上。远程Kafka主题是通过Kerberos保护的。
我们使用的是IBM jdk，因此jaas类名是
com.ibm.security.auth.module.Krb5LoginModule
JAAS配置需要以下选项
KafkaClient {
com.ibm.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab="/etc/security/keytabs/storm.servi
浏览 6提问于2016-02-03得票数 3
我有一个Java应用程序，它使用JAAS身份验证，因此它需要下面的系统属性。
-Djava.security.auth.login.config=/jaas/conf/client_jaas.conf
我们通过JAVA_OPTS在启动脚本中设置这个系统属性。
-Djava.security.auth.login.config=/jaas/conf/client_jaas.conf“JAVA_OPTS="${JAVA_OPTS}
我试图移动这个应用程序到Kubernetes和设置如下。
"containers": [
{
浏览 0提问于2018-04-09得票数 2
回答已采纳
我有一个春季启动卡夫卡客户端应用程序，其中我有两个消费者听不同的主题和不同的消费群体在卡夫卡。
为了实现这个目标，我需要在下面有两个JAAS (使用不同的keytab文件)
dc-jaas-A.conf
KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
storeKey=true
useTicketCache=false
serviceName="kafka"
浏览 5提问于2021-06-28得票数 0
1回答
我试图通过SASL配置的spring集成模块连接到kafka服务器，并得到错误。
java.lang.IllegalArgumentException:在JAAS配置中找不到“KafkaClient”条目。未设置系统属性“java.security.auth.login.config”
但是，当我构建简单的消费者和投票消息时，一切都很好。有人能告诉我如何关闭JAAS授权或通过它正确地连接吗？这是我的和。谢谢你的回答！
浏览 0提问于2018-09-27得票数 0
我想要做的是- For Clients to Broker communication - use OAUTHBEARER authentication
For Broker to Broker communication - use PLAIN authentication 我有以下JAAS配置： {
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="inter"
password="inter-secret&#
浏览 63提问于2019-05-30得票数 3
我需要将日志写入通过Kerberos保护的Kafka主题。
我使用的是log4j 1.2.17和Kafka 08.2.2。
KafkaLog4jAppender支持的唯一选项是
var topic: String = null
var brokerList: String = null
var compressionType: String = null
var requiredNumAcks: Int = Int.MaxValue
var syncSend: Boolean = false
不允许我设置任何JAAS选项，例如
com.sun.security.auth.module.Krb5
浏览 2提问于2016-02-11得票数 0
回答已采纳
我已经尝试建立一个连接到kafka-message在Bluemix上使用一个自由的Java应用程序。我遵循了docs和git存储库示例。它很好地创建/使用了一个jaas.conf文件，并表示它登录。然而，当一条消息被写入时，它会说“在60000 ms之后无法更新元数据”。为了编写消息，我必须将以下代码添加到server.xml文件中：
<jaasLoginModule id="KafkaClient"
className="org.apache.kafka.common.security.plain.PlainLoginModule
浏览 1提问于2017-05-22得票数 0
回答已采纳
我正在使用Apache kafka版本2。我正在尝试使用用户名和密码(SASL_PLAINTEXT)来实现对Kafka的身份验证，并遵循下面的链接来实现相同的身份验证。 https://developer.ibm.com/hadoop/2017/04/10/kafka-security-mechanism-saslplain/ 我已经根据上面的url更改了配置。但是我的误差越来越小了。 java.lang.IllegalArgumentException: Could not find a 'KafkaServer' or 'sasl_plaintext.KafkaS
浏览 335提问于2020-01-07得票数 2
我正在寻找正则表达式从另一个字符串中提取字符串。
"sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule REQUIRED
storeKey=true principal='test@test.net' validate=true serviceName=esaas
keyTab='<some value>' useKeyTab=true;"
如何在keyTab=之后提取字符串我想要检索单引号内的值-
浏览 52提问于2018-09-07得票数 0
回答已采纳
1回答
JMS标头属性的语法
、、、
我在执行下面的代码时遇到了错误
jmsMsg.setStringProperty("MessageHeader.ServiceName","MyService");
错误是
java.lang.IllegalArgumentException: The property name 'MessageHeader.ServiceName' is not a valid java identifier.
但是根据这个！我的属性名是有效的。
这里出了什么问题？
浏览 2提问于2014-03-05得票数 2
我正在尝试提交一个dataproc作业，它将使用Kerberized集群中的数据。当前的工作解决方案是使dataproc作业提交命令的机器上有jaas配置文件和keytab：
gcloud dataproc jobs submit pyspark \
--cluster MY-CLUSTER --region us-west1 --project MY_PROJECT \
--files my_keytab_file.keytab,my_jaas_file.conf \
--properties spark.driver.extraJavaOptions=-Djava.
浏览 12提问于2022-06-27得票数 0
我使用网络传输- TCP -0.5.1作为creatipn TCP传输。
resultCT <- createTransport host port defaultTCPParameters
但是现在我使用的是包网络传输-TCP-0.6.0，并且由于新的类型得到了一个错误：
createTransportExposeInternals
:: N.HostName
-> N.ServiceName
-> (N.ServiceName -> (N.HostName, N.ServiceName))
-> TCPParameters
-> IO
浏览 2提问于2018-02-14得票数 4
回答已采纳
1回答
我在使用控制台脚本与使用sasl保护的Kafka进行通信时遇到问题。Kafka使用sasl安全，listener为SASL_PLAINTEXT，机制为PLAIN。
我做了什么:我尝试使用一个kafka脚本列出一些数据：
bin/kafka-consumer-groups.sh --bootstrap-server (address) --list
不管我得到了什么
WARN Bootstrap broker (address) disconnected (org.apache.kafka.clients.NetworkClient)
和命令失败，这是可以理解的，因为它是用sasl保护的。
因此
浏览 0提问于2017-08-18得票数 19
回答已采纳
我尝试在水槽中设置KafkaChannel (或KafkaSource)。我经常收到下面的例外
原因: javax.security.auth.login.LoginException:无法登录:客户端被要求输入密码，但是Kafka客户端代码目前不支持从用户那里获取密码。确保将-Djava.security.auth.login.config属性传递给JVM，并将客户端配置为使用票证缓存(使用JAAS配置设置‘useTicketCache=true’)。确保您正在使用的是您试图连接到的Kafka broker的FQDN。无法从用户获取身份验证信息。
我的jaas.conf如下：
Kaf
浏览 5提问于2017-07-13得票数 0
回答已采纳
我试图使用Spark结构化流2.3从Kafka ()读取数据，并将其保存到一个1.1IBMAnalytics引擎集群上的IBM对象存储中。
在创建集群之后，ssh进入其中：
$ ssh clsadmin@myclusterid.bi.services.eu-gb.bluemix.net
创建与Message对话所需的jaas.conf文件：
$ cat << EOF > jaas.conf
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
service
浏览 2提问于2018-08-22得票数 2
回答已采纳
1回答
我尝试在安全模式下使用kafka(0.9.1)。我将使用Spark读取数据，因此必须将JAAS文件传递给JVM。我用这个cmd开始我的工作：
/opt/spark/bin/spark-submit -v --master spark://master1:7077 \
--conf "spark.executor.extraJavaOptions=-Djava.security.auth.login.conf=kafka_client_jaas.conf" \
--files "./conf/kafka_client_jaas.conf,./
浏览 3提问于2016-08-08得票数 3
我试图使用Java运行我的Kafka Streams应用程序，并以K，V对的形式将我的汇合凭证作为环境变量传递。
但我面临一个错误的问题，因为-
- org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
Caused by: java.lang.IllegalArgum
浏览 16提问于2022-01-10得票数 0
我正在尝试对KafkaConsumer使用kerberos身份验证。 为此，我添加了以下属性。 props.put("security.protocol", "SASL_PLAINTEXT"); // Setting this means we try to look in jaas.conf
props.put("sasl.kerberos.service.name", "kafka"); 但是，我收到一个错误消息： java.lang.IllegalArgumentException: Could not f
浏览 166提问于2019-09-19得票数 0
回答已采纳
我正在尝试将SASL_PLAINTEXT身份验证配置为kafka，下面是我的配置。
advertised.listeners=SASL_PLAINTEXT://127.0.0.1:9092
listeners=SASL_PLAINTEXT://127.0.0.1:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
sasl.jaas.config=/var/lib/kafka/config/kafk
浏览 0提问于2019-05-07得票数 0
我有一个JSON文件，它是一个对象数组。我希望解析该文件并使用shell脚本从其中读取数据。
file.json:-
[
{
"serviceName": "CreateAssociationService",
"targetJarFile": "../../create-association-service/target/create-association-service-1.0.0-aws.jar",
"function_name": "CreateAssociationServic
浏览 4提问于2020-03-24得票数 0
回答已采纳
1回答
当我在ghci / cabal repl中加载某个文件时，会收到以下错误消息：
No instance for (Control.Monad.Trans.Class.MonadTrans
(EitherT Error))
arising from a use of ‘lift’
但是，EitherT a绝对是MonadTrans的一个实例；它是包的一部分。cabal build也成功了。ghci和cabal repl似乎不知道EitherT类型实例(liftIO会产生类似的错误)，因为某种原因(但cabal build对此很满意)？
以前有没有人遇到过
浏览 3提问于2015-03-06得票数 1
回答已采纳
我只是尝试使用弹性搜索，然后运行了以下查询：
curl -XPOST "http://host/logstash-2016.05.19/_search" -d'
{
"query": {
{ "match": { "serviceName": "systemA" } }
}
}'
但是继续得到这个错误：
{
"error": "SearchPhaseExecutionException[Failed to execute phase [quer
浏览 0提问于2016-05-21得票数 1
回答已采纳
尝试在本地运行Aries 2服务并获得异常：
SEVERE: [localhost]:7750 [local] [4.2.2] Target is this node! -> [localhost]:7750
java.lang.IllegalArgumentException: Target is this node! -> [localhost]:7750
at com.hazelcast.spi.impl.operationservice.impl.OutboundResponseHandler.checkTarget(OutboundResponseHandler.
浏览 7提问于2022-09-26得票数 0
1回答
我有这个组件
<script>
const serviceName = 'events'
import { mapState } from 'vuex'
import crud from './mixins/crud'
export default {
mixins: [crud],
data() {
return {
serviceName: serviceName,
apiBaseUri: '/api/v1/' + servi
浏览 1提问于2018-10-16得票数 0
我有一个用于wurstmeister/kafka的基本文件
我试图将它配置为与SSL一起使用SASL_PLAIN，但是无论我试图指定jaas文件的方式有多少种，我仍然会得到这个错误。
这就是我所犯的错误
[2018-04-11 10:34:34,545] FATAL [KafkaServer id=1001] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.IllegalArgumentException: Could not find a '
浏览 2提问于2018-04-11得票数 2
回答已采纳
1回答
用这个代码
import Control.Monad
import Control.Applicative
import Control.Monad.State
class DefVal a where
defVal :: a
instance (DefVal a) => Alternative (Either a) where
empty = Left defVal
(Left _) <|> x = x
x <|> _ = x
instance (DefVal a) => MonadPlus (Either a) whe
浏览 4提问于2015-08-29得票数 5
回答已采纳
我是从mqtt到骆驼消费，并试图发表到融合卡夫卡，但当我生产卡夫卡，我得到以下错误
java.lang.IllegalArgumentException: Login module control flag is not available in the JAAS config
at org.apache.kafka.common.security.JaasConfig.loginModuleControlFlag(JaasConfig.java:85) ~[kafka-clients-3.1.1.jar:na]
at org.apache.kafka.common.secur
浏览 19提问于2022-06-04得票数 0
我正在尝试使用来自logstash的IBM消息中心。我的logstash.conf：
input {
kafka {
bootstrap_servers => "kafka04-prod01.messagehub.services.eu-de.bluemix.net:9093,kafka05-prod01.messagehub.services.eu-de.bluemix.net:9093,kafka01-prod01.messagehub.services.eu-de.bluemix.net:9093,kafka03-prod01.messagehub
浏览 3提问于2017-10-08得票数 0
回答已采纳
有谁有使用kafka stream和spring boot将消息作为流读取的hello world示例。 我的kafka集群是受SASL_安全保护的。那么我如何将我的spring boot kafka流应用程序与。在application.properties文件中写什么。 我不想用春天的云溪。 server.port=8084
topic.name=test-topic
server.servlet.context-path=/api/v1
spring.application.name=kafkatest
spring.kafka.bootstrap-servers=********
浏览 21提问于2020-07-10得票数 0
TL;DR:为什么当用户身份验证失败时，LDAPLoginModule (显然)不抛出FailedLoginException？
我重写了jboss 6.2.0\1中默认的"karaf“jaas领域。我的配置有两个模块：
通过LDAP到Active链接对用户进行身份验证的org.apache.karaf.jaas.modules.ldap.LDAPLoginModule实例。
MyCustomLoginModule extends AbstractKarafLoginModule -检查本地定义的用户角色的第二个模块。
后者效果很好。但是，当LDAPLoginModu
浏览 0提问于2016-11-10得票数 0
回答已采纳
1回答
下面的函数有一般的或特定的错误。
scala> trait Error
defined trait Error
scala> case object General extends Error
defined object General
scala> trait FooError extends Error
defined trait FooError
scala> case object FooError42 extends FooError
defined object FooError42
然后，有两个功能：
scala> def f: Either
浏览 2提问于2015-07-25得票数 0
假设我的应用有两种类型的错误：
λ: data AppError = FailedLogin | InvalidMessage deriving Show
它有login和sendMessage函数：
λ: let login user pw = Left FailedLogin :: Either AppError String
λ: let sendMessage msg token = Left InvalidMessage :: Either AppError Int
λ: login "foo" "bar" >>= (\token ->
浏览 1提问于2016-01-14得票数 1
我正在尝试将NIFI连接到IBM，但我没有得到任何连接的工作。
有人有关于如何配置它的工作示例吗？
我在公告板上得到了一个超时例外。
我已经配置了一个PublishKafka__11 1.4.0处理器。将其配置为SASL_SSL，添加了标准ssl上下文服务，添加了jaas.conf
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
serviceName="Message Hub-bq"
username="xxxxxx"
password
浏览 4提问于2017-11-24得票数 1
回答已采纳
考虑官方中的以下代码
function createInjector(modulesToLoad, strictDi) {
strictDi = (strictDi === true);
var testingScope = 'this is a test';
var INSTANTIATING = {},
providerSuffix = 'Provider',
path = [],
loadedModules = new HashMap([], true),
providerCache = {
浏览 3提问于2016-08-01得票数 0
回答已采纳
当我试图改变我的表的列长度时，我得到以下Oracle错误：
SQL Error: ORA-30556: either functional or bitmap join index is defined on the column to be modified
30556. 00000 - "either functional or bitmap join index is defined on the column to be modified"
*Cause: An ALTER TABLE MODIFY COLUMN was issued on a colum
浏览 0提问于2018-09-04得票数 2
回答已采纳
我正在设置一个单节点集群。我正在学习教程。然而，我的nodemanager并没有启动。
14468 SecondaryNameNode
14648 ResourceManager
14074 NameNode
15293 Jps
14223 DataNode
以下是节点管理器日志：
2020-08-07 14:13:52,796 FATAL org.apache.hadoop.yarn.server.nodemanager.containermanager.AuxServices: Failed to initialize mapreduce_shuffle
java.lang.Illega
浏览 6提问于2020-08-07得票数 0
我创建了一个启用kafka的事件集线器命名空间，并创建了一个带有“管理、发送和侦听”访问策略的listen。我能够生成这条消息，但得到错误"org.apache.kafka.common.errors.TopicAuthorizationException:没有授权访问主题：“。
我的Akka消费者中的参数是：
akka.kafka.consumer {
#Akka Kafka consumer properties defined here
wakeup-timeout=60s
# Properties defined by org.apache.kafka.clien
浏览 0提问于2018-10-03得票数 1
回答已采纳
1回答
我有以下代码(转换类似于转换)
instance {-# OVERLAPS #-} Transformable a a where
transform x = x
instance {-# OVERLAPPABLE #-} (Transformable l l', Transformable r r' )
=> Transformable (Either l r) (Either l' r')
where
transform = bimap transform transform
当然，在我试图将Either a b
浏览 3提问于2016-04-28得票数 11
回答已采纳
1回答
我正在为下列数据结构实现可折叠：
data Tree a = Leaf a | Node (Tree a) (Tree a) deriving Show
当我实现折叠和foldMap时：
instance Foldable Tree where
--fold :: Monoid a => Tree a -> a
fold (Leaf x) = x
fold (Node l r) = fold l `mappend` fold r
--foldMap :: Monoid b => (a -> b) -> Tree a -> b
foldMap f (L
浏览 0提问于2017-05-05得票数 1
回答已采纳
来自Haskell，我很难找到一种在Purescript的REPL中查找类型定义的简单方法。在Haskell，我可以在GHCI中执行以下操作：
-- type class
:info Monad
-- shortcut
:i Monad
-- concrete types
:i []
:i (->)
-- type constructors work as well with a minimized output
:i Just
type Monad :: (* -> *) -> Constraint
class Applicative m => Monad m w
浏览 7提问于2022-04-12得票数 0
回答已采纳
Siddhi向我抛出没有这样的文件异常，但文件确实在那里(我已经从控制台复制了路径)。我也尝试过添加file://，但也没有成功。 @source(type='kafka',
topic.list='pruebasSiddhi',
partition.no.list='0',
threading.option='single.thread',
group.id='id1',
bootstrap.servers=
浏览 31提问于2021-08-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
