Member since
01-23-2018
70
Posts
3
Kudos Received
6
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 2406 | 01-16-2019 10:05 AM |
01-23-2019
08:44 AM
@Geoffrey Shelton Okot I compared files, yes their exists and the same.
... View more
01-23-2019
07:47 AM
@Geoffrey Shelton Okot I set next acl on Dev cluster: [zk: localhost:2181(CONNECTED) 1] getAcl /brokers
'world,'anyone
: cdrwa
'sasl,'kafka
: cdrwa
[zk: localhost:2181(CONNECTED) 2] getAcl /controller
'world,'anyone
: r
'sasl,'kafka
: cdrwa
[zk: localhost:2181(CONNECTED) 3] getAcl /config
'world,'anyone
: cdrwa
'sasl,'kafka
: cdrwa
[zk: localhost:2181(CONNECTED) 4] getAcl /config/topics
'world,'anyone
: cdrwa
'sasl,'kafka
: cdrwa
but kafka-console-consumer.sh --bootstrap-server still not work.
... View more
01-23-2019
06:44 AM
@Geoffrey Shelton Okot Working Test: [zk: localhost:2181(CONNECTED) 0] getAcl /config/topics
'world,'anyone
: r
'sasl,'kafka
: cdrwa
[zk: localhost:2181(CONNECTED) 1] Not working Dev: [zk: localhost:2181(CONNECTED) 0] getAcl /config/topics
'world,'anyone
: cdrwa
[zk: localhost:2181(CONNECTED) 1]
... View more
01-22-2019
06:21 PM
@Geoffrey Shelton Okot It's real case at my work. I configured Test cluster from Hortonworks documentation and everything works good but at the same time Development cluster with same configuration doesn't work and i don't understand why it is. I don't have lab or some special instruction but i can to show you anything my config files or screenshots. Is it maybe some problem with zookeeper?
... View more
01-22-2019
03:23 PM
@Geoffrey Shelton Okot I use HDF on HDP as one cluster, yes is kerberized. Ambari-2.6.2.2, HDP-2.6.5, HDF-3.1.2.
... View more
01-22-2019
02:34 PM
I can't connect with --bootstrap-server key, only with --zookeeper works. Obviously "ConsumeKafka processor" use "bootstrap" mod. Can i use zookeeper with "ConsumeKafka processor" or how can i debug why i can't to connect direct to broker? kafka-console-consumer.sh --bootstrap-server server:6667 --topic test5 --from-beginning --security-protocol SASL_PLAINTEXT
don't work kafka-console-consumer.sh --zookeeper server:2181--topic test5 --from-beginning --security-protocol SASL_PLAINTEXT
work fine
... View more
01-17-2019
02:54 PM
Hello, I have enable kerberos on cluster. I can successfully connect to consumer through kafka-konsole-consumer. But when i try to connect to topic through NiFi ConsumeKafka processor i have error: WARN [Timer-Driven Process Thread-8] o.a.n.p.kafka.pubsub.ConsumeKafka_1_0 ConsumeKafka_1_0[id=504e5811-0168-1000-0000-000024c83cc5] Was interrupted while trying to communicate with Kafka with lease org.apache.nifi.processors.kafka.pubsub.ConsumerPool$SimpleConsumerLease@51911c24. Will roll back session and discard any partially received data. WARN [kafka-kerberos-refresh-thread-nifi/*@*] o.a.k.c.security.kerberos.KerberosLogin [Principal=nifi/*@*]: TGT renewal thread has been interrupted and will exit.
... View more
Labels:
- Labels:
-
Apache Kafka
-
Apache NiFi
01-16-2019
10:05 AM
My stupid mistake, i forgot what i had enabled manual commit in Dbeaver in production server and "upgrade_id" cell didn't update.
... View more
01-15-2019
02:59 PM
Maybe is that problem because one item in last update was failed? {
"href" : "http://*:8080/api/v1/clusters/DataLake/upgrades/865/upgrade_groups/434/upgrade_items/140",
"UpgradeItem" : {
"cluster_name" : "DataLake",
"command_params" : "{\"upgrade_pack\":\"nonrolling-upgrade-2.6\",\"clusterName\":\"DataLake\",\"upgrade_direction\":\"upgrade\",\"forceRefreshConfigTagsBeforeExecution\":\"true\",\"upgrade_type\":\"nonrolling_upgrade\",\"request_id\":\"865\"}",
"context" : "Save Cluster State",
"display_status" : "FAILED",
"end_time" : -1,
"group_id" : 434,
"host_params" : "{\"host_sys_prepped\":\"false\",\"agent_stack_retry_count\":\"5\",\"java_home\":\"/etc/alternatives/java_sdk\",\"jdk_location\":\"http://*.*.ru:8080/resources/\",\"stack_version\":\"2.6\",\"custom_postgres_jdbc_name\":\"postgresql-42.0.0.jar\",\"mysql_jdbc_url\":\"http://*:8080/resources//mysql-connector-java.jar\",\"oracle_jdbc_url\":\"http://*:8080/resources//ojdbc6.jar\",\"ambari_db_rca_password\":\"SECRET\",\"db_name\":\"ambari\",\"ambari_db_rca_driver\":\"org.postgresql.Driver\",\"ambari_db_rca_username\":\"ambari\",\"java_version\":\"8\",\"previous_custom_postgres_jdbc_name\":\"postgresql-42.0.0.jar\",\"not_managed_hdfs_path_list\":\"[\\\"/data/apps/hive/warehouse\\\",\\\"/data/app-logs\\\",\\\"/data/mr-history/done\\\",\\\"/tmp\\\"]\",\"db_driver_filename\":\"mysql-connector-java.jar\",\"gpl_license_accepted\":\"false\",\"agent_stack_retry_on_unavailability\":\"false\",\"ambari_db_rca_url\":\"jdbc:postgresql://*:5432/ambari\",\"stack_name\":\"HDP\"}",
"log_info" : null,
"progress_percent" : 100.0,
"request_id" : 865,
"skippable" : true,
"stage_id" : 140,
"start_time" : 1526474555466,
"status" : "COMPLETED",
"text" : "Save Cluster State"
},
"tasks" : [
{
"href" : "http://*:8080/api/v1/clusters/DataLake/upgrades/865/upgrade_groups/434/upgrade_items/140/tasks/11045",
"Tasks" : {
"cluster_name" : "DataLake",
"id" : 11045,
"request_id" : 865,
"stage_id" : 140
}
}
]
}
... View more
01-15-2019
01:10 PM
Hello, When installing new HDP version in Ambari, the following error is displayed: "Cluster <cluster_name> upgrade is in progress. Cannot install packages." I had tried to use instruction like this https://community.hortonworks.com/content/supportkb/177629/errorcluster-xyz-upgrade-is-in-progress-cannot-ins.html But not successfully. How can i work around this problem?
... View more
Labels:
- « Previous
-
- 1
- 2
- Next »