fuyun fuyuntt

本文主要介绍下 kafka 0.10.0 版如何实现sasl/plain认证机制及权限控制

kakfa 的安全机制主要分为两部分：

kafka 目前支持 SSL，SASL(Kerberos)，SASL（PLAIN) 三种认证机制。

	package com.best.buc.base.manager.serialnum.generator.seq;

	import org.apache.commons.lang.ArrayUtils;

	import java.util.Collections;
	import java.util.List;
	import java.util.stream.Collectors;
	import java.util.stream.IntStream;

	/**

	import com.google.common.geometry.{MutableInteger, S2CellId}

	/**
	* Created by fuyun on 2017/7/25.
	*/
	object ImproveS2 {
	val level = 17
	// at level 17
	def cellIj(cell: S2CellId): (Int, Int) = {
	val i = new MutableInteger(0)

	package com.fuyun.scala;

	import java.io.IOException;
	import java.net.InetSocketAddress;
	import java.nio.ByteBuffer;
	import java.nio.CharBuffer;
	import java.nio.channels.SelectionKey;
	import java.nio.channels.Selector;
	import java.nio.channels.ServerSocketChannel;
	import java.nio.channels.SocketChannel;