hi. as subj. states, I'm trying to use kafka-0.8.1.1 with samza (0.7). Initially the work started as a dev. user, e.g. "devuser", and kafka would run as that user, "and it's been good".
Then, during the deployment attempt, we're trying to run kafka under a different user, "kafka". After having that set up, for some reason we get "no leader" problem. That is the topics are "leaderless". This is consistent either using the lib from java OR the command line tools. Our zookeeper comes from cloudera's hadoop (CDH4 and 5 behave the same way). But alas, when run as devuser the problem does not happen, so I don't think the problem is zookeeper's version and we did not enable any zookeeper authentication mechanisms. I thought the communication with both kafka and zookeeper is done via a tcp socket, so as long as the connections occur, and corresponding services can work, there should not be any relation between the username of either consumer, producer or the service. Maybe I'm missing something fundamental, but: Is it supposed to behave like that? I can provide more "solid" info (like command excerpts, logs, etc. upon request) Thanks in advance, Max.
