Off the top of my head sounds like directory permission/ownership issue for data. On Jun 15, 2014 5:05 AM, "Max Kovgan" <m...@fortscale.com> wrote:
> 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. >
