Created 01-30-2018 06:11 PM
HI,
ive upgrades HDP from 2.4 to 2.5 to 2.6. now kafka is at 0.10.1 . im have Kerberos configured and working with Ranger
I can create , produce , and consuming with zookeeper ( usinf kinit and a user that have permissions at Ranger rule)
WORKING OK ./kafka-console-producer.sh --broker-list ctl-t01.my.domain:6667,ctl-t02.my.domain:6667,ctl-t01.my.domain:6667 --topic bptopic --security-protocol PLAINTEXTSASL ./kafka-console-consumer.sh --bootstrap-server ctl-t01.my.domain:2181:6667 --topic bptopic --security-protocol PLAINTEXTSASL --from-beginning
when i use the Brokers instead of zookeper , the consumer , is not consuming
NOT WORKING ./kafka-console-consumer.sh --zookeeper ctl-t01.my.domain:2181 --topic bptopic--security-protocol PLAINTEXTSASL --from-beginning
i have cheked logs , and documentation , without any solution.
Could be , that i need to delete at zookepper rmr /brokers? ( im not sure, but in another environment , that was the solution. deleting all the topics..). i want to see if i can keep all the topics , since we keep them for more than a week, and deleting them will be the last resource.
thanks much
Created 01-31-2018 04:13 PM
seem to be that deleting the brokers at zookeper do the trick .
yet all the topic need to be recreated, and the data of the topics will be lost
Created 01-31-2018 04:13 PM
seem to be that deleting the brokers at zookeper do the trick .
yet all the topic need to be recreated, and the data of the topics will be lost
Created 02-05-2018 04:52 PM
First backup some metadata related to your topics
su - kafka >sript> for i in `/usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --zookeeper server-02:2181 --list --security-protocol PLAINTEXTSASL 2>&1 ` do echo $i /usr/hdp/current/kafka-broker/bin/kafka-consumer-groups.sh --zookeeper server-01:2181 --group $i --describe done <script<
describe topics
/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --describe --zookeeper sr-hadctl-xt01:2181 --topic bptopic
now remove the brokers metadata fron zookeeper
/usr/hdp/current/zookeeper-client/bin/zkCli.sh -server `hostname -f`:2181 rmr /brokers
Altering retention time OPTION 1 [root@server-02 ~]# /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --zookeeper server-01:2181 --alter --topic bptopic --config retention.ms=86400000 WARNING: Altering topic configuration from this script has been deprecated and may be removed in future releases. Going forward, please use kafka-configs.sh for this functionality Updated config for topic "bptopic". OPTION 2 [root@server-02 ~]# /usr/hdp/current/kafka-broker/bin/kafka-configs.sh --zookeeper sr-hadctl-xt01:2181 --alter --entity-type topics --entity-name bptopic --add-config 'retention.ms=864000 Check config [root@server-02 ~]# /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --describe --zookeeper sr-hadctl-xt01:2181 --topic bptopic Topic:bptopic PartitionCount:1 ReplicationFactor:1 Configs:retention.ms=86400000 Topic: bptopic Partition: 0 Leader: 1001 Replicas: 1001 Isr: 1001 |
Created 02-06-2018 03:28 PM
There is a way to do the upgrade, and keeping the kafka-logs data?