[2017-04-03 10:03:40,947] INFO KafkaConfig values: advertised.host.name = null advertised.listeners = null advertised.port = null authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer auto.create.topics.enable = true auto.leader.rebalance.enable = true background.threads = 10 broker.id = 0 broker.id.generation.enable = true broker.rack = null compression.type = producer connections.max.idle.ms = 600000 controlled.shutdown.enable = true controlled.shutdown.max.retries = 3 controlled.shutdown.retry.backoff.ms = 5000 controller.socket.timeout.ms = 30000 default.replication.factor = 1 delete.topic.enable = false fetch.purgatory.purge.interval.requests = 1000 group.max.session.timeout.ms = 300000 group.min.session.timeout.ms = 6000 host.name = inter.broker.protocol.version = 0.10.1-IV2 leader.imbalance.check.interval.seconds = 300 leader.imbalance.per.broker.percentage = 10 listeners = SASL_PLAINTEXT://kafka.example.com:9092 log.cleaner.backoff.ms = 15000 log.cleaner.dedupe.buffer.size = 134217728 log.cleaner.delete.retention.ms = 86400000 log.cleaner.enable = true log.cleaner.io.buffer.load.factor = 0.9 log.cleaner.io.buffer.size = 524288 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 log.cleaner.min.cleanable.ratio = 0.5 log.cleaner.min.compaction.lag.ms = 0 log.cleaner.threads = 1 log.cleanup.policy = [delete] log.dir = /tmp/kafka-logs log.dirs = /tmp/kafka-logs log.flush.interval.messages = 9223372036854775807 log.flush.interval.ms = null log.flush.offset.checkpoint.interval.ms = 60000 log.flush.scheduler.interval.ms = 9223372036854775807 log.index.interval.bytes = 4096 log.index.size.max.bytes = 10485760 log.message.format.version = 0.10.1-IV2 log.message.timestamp.difference.max.ms = 9223372036854775807 log.message.timestamp.type = CreateTime log.preallocate = false log.retention.bytes = -1 log.retention.check.interval.ms = 300000 log.retention.hours = 168 log.retention.minutes = null log.retention.ms = null log.roll.hours = 168 log.roll.jitter.hours = 0 log.roll.jitter.ms = null log.roll.ms = null log.segment.bytes = 1073741824 log.segment.delete.delay.ms = 60000 max.connections.per.ip = 2147483647 max.connections.per.ip.overrides = message.max.bytes = 1000012 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 min.insync.replicas = 1 num.io.threads = 8 num.network.threads = 3 num.partitions = 1 num.recovery.threads.per.data.dir = 1 num.replica.fetchers = 1 offset.metadata.max.bytes = 4096 offsets.commit.required.acks = -1 offsets.commit.timeout.ms = 5000 offsets.load.buffer.size = 5242880 offsets.retention.check.interval.ms = 600000 offsets.retention.minutes = 1440 offsets.topic.compression.codec = 0 offsets.topic.num.partitions = 50 offsets.topic.replication.factor = 3 offsets.topic.segment.bytes = 104857600 port = 9092 principal.builder.class = class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder producer.purgatory.purge.interval.requests = 1000 queued.max.requests = 500 quota.consumer.default = 9223372036854775807 quota.producer.default = 9223372036854775807 quota.window.num = 11 quota.window.size.seconds = 1 replica.fetch.backoff.ms = 1000 replica.fetch.max.bytes = 1048576 replica.fetch.min.bytes = 1 replica.fetch.response.max.bytes = 10485760 replica.fetch.wait.max.ms = 500 replica.high.watermark.checkpoint.interval.ms = 5000 replica.lag.time.max.ms = 10000 replica.socket.receive.buffer.bytes = 65536 replica.socket.timeout.ms = 30000 replication.quota.window.num = 11 replication.quota.window.size.seconds = 1 request.timeout.ms = 30000 reserved.broker.max.id = 1000 sasl.enabled.mechanisms = [GSSAPI] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.principal.to.local.rules = [DEFAULT] sasl.kerberos.service.name = kafka sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism.inter.broker.protocol = GSSAPI security.inter.broker.protocol = SASL_PLAINTEXT socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS unclean.leader.election.enable = true zookeeper.connect = kafka.example.com:2182 zookeeper.connection.timeout.ms = 6000 zookeeper.session.timeout.ms = 6000 zookeeper.set.acl = false zookeeper.sync.time.ms = 2000 (kafka.server.KafkaConfig) [2017-04-03 10:03:41,032] INFO starting (kafka.server.KafkaServer) [2017-04-03 10:03:41,050] INFO [ThrottledRequestReaper-Fetch], Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2017-04-03 10:03:41,052] INFO [ThrottledRequestReaper-Produce], Starting (kafka.server.ClientQuotaManager$ThrottledRequestReaper) [2017-04-03 10:03:41,058] INFO Connecting to zookeeper on kafka.example.com:2182 (kafka.server.KafkaServer) [2017-04-03 10:03:41,069] INFO JAAS File name: /etc/kafka/kafka_server_jaas.conf (org.I0Itec.zkclient.ZkClient) [2017-04-03 10:03:41,071] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2017-04-03 10:03:41,080] INFO Client environment:zookeeper.version=3.4.8--1, built on 02/06/2016 03:18 GMT (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:host.name=kafka.example.com (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.version=1.8.0_121 (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.home=/usr/lib/jvm/java-8-oracle/jre (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.class.path=:/etc/kafka/bin/../libs/aopalliance-repackaged-2.4.0-b34.jar:/etc/kafka/bin/../libs/argparse4j-0.5.0.jar:/etc/kafka/bin/../libs/connect-api-0.10.1.1.jar:/etc/kafka/bin/../libs/connect-file-0.10.1.1.jar:/etc/kafka/bin/../libs/connect-json-0.10.1.1.jar:/etc/kafka/bin/../libs/connect-runtime-0.10.1.1.jar:/etc/kafka/bin/../libs/guava-18.0.jar:/etc/kafka/bin/../libs/hk2-api-2.4.0-b34.jar:/etc/kafka/bin/../libs/hk2-locator-2.4.0-b34.jar:/etc/kafka/bin/../libs/hk2-utils-2.4.0-b34.jar:/etc/kafka/bin/../libs/jackson-annotations-2.6.0.jar:/etc/kafka/bin/../libs/jackson-core-2.6.3.jar:/etc/kafka/bin/../libs/jackson-databind-2.6.3.jar:/etc/kafka/bin/../libs/jackson-jaxrs-base-2.6.3.jar:/etc/kafka/bin/../libs/jackson-jaxrs-json-provider-2.6.3.jar:/etc/kafka/bin/../libs/jackson-module-jaxb-annotations-2.6.3.jar:/etc/kafka/bin/../libs/javassist-3.18.2-GA.jar:/etc/kafka/bin/../libs/javax.annotation-api-1.2.jar:/etc/kafka/bin/../libs/javax.inject-1.jar:/etc/kafka/bin/../libs/javax.inject-2.4.0-b34.jar:/etc/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/etc/kafka/bin/../libs/javax.ws.rs-api-2.0.1.jar:/etc/kafka/bin/../libs/jersey-client-2.22.2.jar:/etc/kafka/bin/../libs/jersey-common-2.22.2.jar:/etc/kafka/bin/../libs/jersey-container-servlet-2.22.2.jar:/etc/kafka/bin/../libs/jersey-container-servlet-core-2.22.2.jar:/etc/kafka/bin/../libs/jersey-guava-2.22.2.jar:/etc/kafka/bin/../libs/jersey-media-jaxb-2.22.2.jar:/etc/kafka/bin/../libs/jersey-server-2.22.2.jar:/etc/kafka/bin/../libs/jetty-continuation-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-http-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-io-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-security-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-server-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-servlet-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-servlets-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jetty-util-9.2.15.v20160210.jar:/etc/kafka/bin/../libs/jopt-simple-4.9.jar:/etc/kafka/bin/../libs/kafka_2.11-0.10.1.1.jar:/etc/kafka/bin/../libs/kafka_2.11-0.10.1.1-sources.jar:/etc/kafka/bin/../libs/kafka_2.11-0.10.1.1-test-sources.jar:/etc/kafka/bin/../libs/kafka-clients-0.10.1.1.jar:/etc/kafka/bin/../libs/kafka-log4j-appender-0.10.1.1.jar:/etc/kafka/bin/../libs/kafka-streams-0.10.1.1.jar:/etc/kafka/bin/../libs/kafka-streams-examples-0.10.1.1.jar:/etc/kafka/bin/../libs/kafka-tools-0.10.1.1.jar:/etc/kafka/bin/../libs/log4j-1.2.17.jar:/etc/kafka/bin/../libs/lz4-1.3.0.jar:/etc/kafka/bin/../libs/metrics-core-2.2.0.jar:/etc/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/etc/kafka/bin/../libs/reflections-0.9.10.jar:/etc/kafka/bin/../libs/rocksdbjni-4.9.0.jar:/etc/kafka/bin/../libs/scala-library-2.11.8.jar:/etc/kafka/bin/../libs/scala-parser-combinators_2.11-1.0.4.jar:/etc/kafka/bin/../libs/slf4j-api-1.7.21.jar:/etc/kafka/bin/../libs/slf4j-log4j12-1.7.21.jar:/etc/kafka/bin/../libs/snappy-java-1.1.2.6.jar:/etc/kafka/bin/../libs/validation-api-1.1.0.Final.jar:/etc/kafka/bin/../libs/zkclient-0.9.jar:/etc/kafka/bin/../libs/zookeeper-3.4.8.jar (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:os.version=4.4.0-31-generic (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:user.name=sliman (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:user.home=/home/sliman (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,080] INFO Client environment:user.dir=/etc/kafka (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,081] INFO Initiating client connection, connectString=kafka.example.com:2182 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@694abbdc (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:41,097] INFO Waiting for keeper state SaslAuthenticated (org.I0Itec.zkclient.ZkClient) >>> KeyTabInputStream, readName(): EXAMPLE.COM >>> KeyTabInputStream, readName(): kafka >>> KeyTabInputStream, readName(): kafka.example.com >>> KeyTab: load() entry length: 78; type: 16 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Java config name: /etc/krb5.conf Loaded from Java config Added key: 16version: 3 >>> KdcAccessibility: reset Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 default etypes for default_tkt_enctypes: 16. >>> KrbAsReq creating message >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=153 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=153 >>> KrbKdcReq send: #bytes read=350 >>>Pre-Authentication Data: PA-DATA type = 136 >>>Pre-Authentication Data: PA-DATA type = 11 PA-ETYPE-INFO etype = 16, salt = EXAMPLE.COMkafkakafka.example.com >>>Pre-Authentication Data: PA-DATA type = 19 PA-ETYPE-INFO2 etype = 16, salt = EXAMPLE.COMkafkakafka.example.com, s2kparams = null >>>Pre-Authentication Data: PA-DATA type = 2 PA-ENC-TIMESTAMP >>>Pre-Authentication Data: PA-DATA type = 133 >>> KdcAccessibility: remove kafka.example.com:88 >>> KDCRep: init() encoding tag is 126 req type is 11 >>>KRBError: cTime is Wed Oct 23 11:58:13 WET 1996 846071893000 sTime is Mon Apr 03 10:03:41 WEST 2017 1491210221000 suSec is 202280 error code is 25 error Message is Additional pre-authentication required cname is kafka/kafka.example.com@EXAMPLE.COM sname is krbtgt/EXAMPLE.COM@EXAMPLE.COM eData provided. msgType is 30 >>>Pre-Authentication Data: PA-DATA type = 136 >>>Pre-Authentication Data: PA-DATA type = 11 PA-ETYPE-INFO etype = 16, salt = EXAMPLE.COMkafkakafka.example.com >>>Pre-Authentication Data: PA-DATA type = 19 PA-ETYPE-INFO2 etype = 16, salt = EXAMPLE.COMkafkakafka.example.com, s2kparams = null >>>Pre-Authentication Data: PA-DATA type = 2 PA-ENC-TIMESTAMP >>>Pre-Authentication Data: PA-DATA type = 133 KRBError received: NEEDED_PREAUTH KrbAsReqBuilder: PREAUTH FAILED/REQ, re-send AS-REQ default etypes for default_tkt_enctypes: 16. Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 default etypes for default_tkt_enctypes: 16. >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbAsReq creating message >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=244 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=244 >>> KrbKdcReq send: #bytes read=817 >>> KdcAccessibility: remove kafka.example.com:88 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbAsRep cons in KrbAsReq.getReply kafka/kafka.example.com [2017-04-03 10:03:41,393] INFO successfully logged in. (org.apache.zookeeper.Login) [2017-04-03 10:03:41,396] INFO TGT refresh thread started. (org.apache.zookeeper.Login) [2017-04-03 10:03:41,400] INFO Client will use GSSAPI as SASL mechanism. (org.apache.zookeeper.client.ZooKeeperSaslClient) [2017-04-03 10:03:41,409] INFO Opening socket connection to server kafka.example.com/127.0.0.1:2182. Will attempt to SASL-authenticate using Login Context section 'Client' (org.apache.zookeeper.ClientCnxn) [2017-04-03 10:03:41,414] INFO TGT valid starting at: Mon Apr 03 10:03:41 WEST 2017 (org.apache.zookeeper.Login) [2017-04-03 10:03:41,414] INFO TGT expires: Mon Apr 03 20:03:41 WEST 2017 (org.apache.zookeeper.Login) [2017-04-03 10:03:41,414] INFO TGT refresh sleeping until: Mon Apr 03 18:09:43 WEST 2017 (org.apache.zookeeper.Login) [2017-04-03 10:03:41,416] INFO Socket connection established to kafka.example.com/127.0.0.1:2182, initiating session (org.apache.zookeeper.ClientCnxn) [2017-04-03 10:03:41,453] INFO Session establishment complete on server kafka.example.com/127.0.0.1:2182, sessionid = 0x15b330c52b30000, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2017-04-03 10:03:41,455] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Entered Krb5Context.initSecContext with state=STATE_NEW Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Service ticket not found in the subject >>> Credentials acquireServiceCreds: same realm default etypes for default_tgs_enctypes: 16. >>> CksumType: sun.security.krb5.internal.crypto.RsaMd5CksumType >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=692 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=692 >>> KrbKdcReq send: #bytes read=670 >>> KdcAccessibility: remove kafka.example.com:88 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbApReq: APOptions are 00000000 00000000 00000000 00000000 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType Krb5Context setting mySeqNumber to: 413519251 Krb5Context setting peerSeqNumber to: 0 Created InitSecContextToken: 0000: 01 00 6E 82 02 5D 30 82 02 59 A0 03 02 01 05 A1 ..n..]0..Y...... 0010: 03 02 01 0E A2 07 03 05 00 00 00 00 00 A3 82 01 ................ 0020: 65 61 82 01 61 30 82 01 5D A0 03 02 01 05 A1 0D ea..a0..]....... 0030: 1B 0B 45 58 41 4D 50 4C 45 2E 43 4F 4D A2 29 30 ..EXAMPLE.COM.)0 0040: 27 A0 03 02 01 00 A1 20 30 1E 1B 09 7A 6F 6F 6B '...... 0...zook 0050: 65 65 70 65 72 1B 11 6B 61 66 6B 61 2E 65 78 61 eeper..kafka.exa 0060: 6D 70 6C 65 2E 63 6F 6D A3 82 01 1A 30 82 01 16 mple.com....0... 0070: A0 03 02 01 10 A1 03 02 01 03 A2 82 01 08 04 82 ................ 0080: 01 04 EC 1F C5 5C 81 86 A6 FB D0 8B 7F 90 45 87 .....\........E. 0090: 20 48 F1 31 88 3C 3C EC 8F 82 4D 29 98 60 F8 4A H.1.<<...M).`.J 00A0: 0F 9C 59 65 21 0E EB 32 C4 3A F8 A7 18 B8 A4 51 ..Ye!..2.:.....Q 00B0: C2 9E 3C 65 EC 39 6A 4F B4 48 1F D2 1D B5 67 78 ..Z..... 00D0: DC E4 21 30 22 4B 4B 8B A9 D6 B0 BF 60 93 3E A4 ..!0"KK.....`.>. 00E0: 35 E9 02 6E A7 EA 6A 83 BC 91 D6 1C 8F 24 F3 9D 5..n..j......$.. 00F0: 79 42 7E 0C B9 E0 29 D9 5A CF 37 6A F3 EC F0 31 yB....).Z.7j...1 0100: CD 38 9D 69 2E A0 D1 43 21 0D 1A 1C 80 90 30 10 .8.i...C!.....0. 0110: 5D 34 75 65 E7 32 59 8D 9D 54 D1 6F 56 60 D7 A0 ]4ue.2Y..T.oV`.. 0120: 00 43 D6 D6 E6 E7 8D 3B B7 83 60 AF D7 03 73 43 .C.....;..`...sC 0130: 9D 03 2D 23 90 A6 30 6C 09 27 6F 08 84 BA FC DE ..-#..0l.'o..... 0140: 1D CF DE 17 FC F0 82 80 82 8D 68 3C D4 0D AB 72 ..........h<...r 0150: 35 25 99 68 40 5E 02 0F BE 01 3B 9F 92 CC 19 B4 5%.h@^....;..... 0160: C5 80 4A 23 F0 0D BE 65 8F 21 55 98 BD 67 4D 48 ..J#...e.!U..gMH 0170: E1 B3 C3 B8 CA 42 68 20 AE C4 36 E9 0F 0B 8A DC .....Bh ..6..... 0180: D4 61 C6 E3 81 9D A4 81 DA 30 81 D7 A0 03 02 01 .a.......0...... 0190: 10 A2 81 CF 04 81 CC 6D 9A 36 A8 F7 E3 8E A0 3A .......m.6.....: 01A0: 6F B0 FD 24 BD 79 BC 95 77 51 85 29 FE 14 53 70 o..$.y..wQ.)..Sp 01B0: C1 AD 30 B2 1A 48 6E 19 20 25 F7 12 0A A7 28 4B ..0..Hn. %....(K 01C0: 8C 26 D3 F1 C2 88 46 B4 92 10 C3 5B 7F B6 CE 84 .&....F....[.... 01D0: 19 79 DF 97 55 4D F2 2A D6 4A 38 FF 63 65 63 5F .y..UM.*.J8.cec_ 01E0: AF 85 07 75 0D F8 9D C5 14 D8 1D AC 45 B5 7A 45 ...u........E.zE 01F0: 6B 6E 4C F0 2D FA 99 59 F0 84 1D 6A FD 3E 4C E9 knL.-..Y...j.>L. 0200: A5 98 86 32 AA 84 9D E5 8F 76 07 9F 39 71 7B 91 ...2.....v..9q.. 0210: 1E 48 14 1F ED EA FA EB E3 F7 1B C4 65 DE 73 29 .H..........e.s) 0220: DF 52 D4 D2 20 32 24 60 AD CA C8 48 46 08 42 DA .R.. 2$`...HF.B. 0230: 6B 44 79 18 CD CE C7 8F 0D B2 5F B2 4D 1B 81 2C kDy......._.M.., 0240: 62 EA 40 56 BF A4 9D 38 FF 02 A8 98 29 A2 1F AF b.@V...8....)... 0250: BD CA 8C 7E BF 49 24 21 65 DA CD 04 44 4F 4C 0D .....I$!e...DOL. 0260: E0 06 E5 ... Krb5Context.unwrap: token=[60 3f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 61 c2 c2 3f c4 3f cf c7 48 9d cd b2 78 af c6 1c 46 c8 54 53 55 9e 67 44 9c 8a be 6a cd 17 da 12 0e 9d 05 1f 01 01 00 00 04 04 04 04 ] Krb5Context.unwrap: data=[01 01 00 00 ] Krb5Context.wrap: data=[01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d ] Krb5Context.wrap: token=[60 5f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 1b 08 ed 4a 75 f6 bf 75 89 b4 04 f9 05 ba fe fa c2 bd da 03 d8 ca 58 28 27 8c 46 03 d6 52 54 c8 0d ab 49 29 01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d 01 ] [2017-04-03 10:03:41,516] INFO zookeeper state changed (SaslAuthenticated) (org.I0Itec.zkclient.ZkClient) [2017-04-03 10:03:41,674] INFO Cluster ID = UW5-PrnLTCWUqHudlNksUg (kafka.server.KafkaServer) [2017-04-03 10:03:41,723] INFO Loading logs. (kafka.log.LogManager) [2017-04-03 10:03:41,728] INFO Logs loading complete in 5 ms. (kafka.log.LogManager) [2017-04-03 10:03:41,814] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2017-04-03 10:03:41,816] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 default etypes for default_tkt_enctypes: 16. >>> KrbAsReq creating message >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=153 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=153 >>> KrbKdcReq send: #bytes read=350 >>>Pre-Authentication Data: PA-DATA type = 136 >>>Pre-Authentication Data: PA-DATA type = 11 PA-ETYPE-INFO etype = 16, salt = EXAMPLE.COMkafkakafka.example.com >>>Pre-Authentication Data: PA-DATA type = 19 PA-ETYPE-INFO2 etype = 16, salt = EXAMPLE.COMkafkakafka.example.com, s2kparams = null >>>Pre-Authentication Data: PA-DATA type = 2 PA-ENC-TIMESTAMP >>>Pre-Authentication Data: PA-DATA type = 133 >>> KdcAccessibility: remove kafka.example.com:88 >>> KDCRep: init() encoding tag is 126 req type is 11 >>>KRBError: cTime is Sun May 08 15:40:55 WET 1994 768411655000 sTime is Mon Apr 03 10:03:41 WEST 2017 1491210221000 suSec is 866300 error code is 25 error Message is Additional pre-authentication required cname is kafka/kafka.example.com@EXAMPLE.COM sname is krbtgt/EXAMPLE.COM@EXAMPLE.COM eData provided. msgType is 30 >>>Pre-Authentication Data: PA-DATA type = 136 >>>Pre-Authentication Data: PA-DATA type = 11 PA-ETYPE-INFO etype = 16, salt = EXAMPLE.COMkafkakafka.example.com >>>Pre-Authentication Data: PA-DATA type = 19 PA-ETYPE-INFO2 etype = 16, salt = EXAMPLE.COMkafkakafka.example.com, s2kparams = null >>>Pre-Authentication Data: PA-DATA type = 2 PA-ENC-TIMESTAMP >>>Pre-Authentication Data: PA-DATA type = 133 KRBError received: NEEDED_PREAUTH KrbAsReqBuilder: PREAUTH FAILED/REQ, re-send AS-REQ default etypes for default_tkt_enctypes: 16. Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 default etypes for default_tkt_enctypes: 16. >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbAsReq creating message >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=244 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=244 >>> KrbKdcReq send: #bytes read=817 >>> KdcAccessibility: remove kafka.example.com:88 Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbAsRep cons in KrbAsReq.getReply kafka/kafka.example.com [2017-04-03 10:03:41,911] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [2017-04-03 10:03:41,912] INFO TGT refresh thread started. (org.apache.kafka.common.security.kerberos.KerberosLogin) [2017-04-03 10:03:41,914] INFO TGT valid starting at: Mon Apr 03 10:03:41 WEST 2017 (org.apache.kafka.common.security.kerberos.KerberosLogin) [2017-04-03 10:03:41,914] INFO TGT expires: Mon Apr 03 20:03:41 WEST 2017 (org.apache.kafka.common.security.kerberos.KerberosLogin) [2017-04-03 10:03:41,914] INFO TGT refresh sleeping until: Mon Apr 03 18:03:53 WEST 2017 (org.apache.kafka.common.security.kerberos.KerberosLogin) [2017-04-03 10:03:41,928] INFO Awaiting socket connections on kafka.example.com:9092. (kafka.network.Acceptor) [2017-04-03 10:03:41,932] INFO [Socket Server on Broker 0], Started 1 acceptor threads (kafka.network.SocketServer) [2017-04-03 10:03:41,955] INFO [ExpirationReaper-0], Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-04-03 10:03:41,956] INFO [ExpirationReaper-0], Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-04-03 10:03:42,006] INFO Creating /controller (is it secure? true) (kafka.utils.ZKCheckedEphemeral) [2017-04-03 10:03:42,020] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral) [2017-04-03 10:03:42,022] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector) [2017-04-03 10:03:42,139] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) [2017-04-03 10:03:42,141] INFO [ExpirationReaper-0], Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-04-03 10:03:42,142] INFO [ExpirationReaper-0], Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-04-03 10:03:42,147] INFO [ExpirationReaper-0], Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2017-04-03 10:03:42,152] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.GroupCoordinator) [2017-04-03 10:03:42,153] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.GroupCoordinator) [2017-04-03 10:03:42,154] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager) [2017-04-03 10:03:42,161] INFO JAAS File name: /etc/kafka/kafka_server_jaas.conf (org.I0Itec.zkclient.ZkClient) [2017-04-03 10:03:42,162] INFO Initiating client connection, connectString=kafka.example.com:2182 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@2f01783a (org.apache.zookeeper.ZooKeeper) [2017-04-03 10:03:42,162] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2017-04-03 10:03:42,162] INFO Client will use GSSAPI as SASL mechanism. (org.apache.zookeeper.client.ZooKeeperSaslClient) [2017-04-03 10:03:42,163] INFO Opening socket connection to server kafka.example.com/127.0.0.1:2182. Will attempt to SASL-authenticate using Login Context section 'Client' (org.apache.zookeeper.ClientCnxn) [2017-04-03 10:03:42,165] INFO Socket connection established to kafka.example.com/127.0.0.1:2182, initiating session (org.apache.zookeeper.ClientCnxn) [2017-04-03 10:03:42,166] INFO Waiting for keeper state SaslAuthenticated (org.I0Itec.zkclient.ZkClient) [2017-04-03 10:03:42,174] INFO Session establishment complete on server kafka.example.com/127.0.0.1:2182, sessionid = 0x15b330c52b30001, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Entered Krb5Context.initSecContext with state=STATE_NEW Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to zookeeper/kafka.example.com@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Found service ticket in the subjectTicket (hex) = 0000: 61 82 01 61 30 82 01 5D A0 03 02 01 05 A1 0D 1B a..a0..]........ 0010: 0B 45 58 41 4D 50 4C 45 2E 43 4F 4D A2 29 30 27 .EXAMPLE.COM.)0' 0020: A0 03 02 01 00 A1 20 30 1E 1B 09 7A 6F 6F 6B 65 ...... 0...zooke 0030: 65 70 65 72 1B 11 6B 61 66 6B 61 2E 65 78 61 6D eper..kafka.exam 0040: 70 6C 65 2E 63 6F 6D A3 82 01 1A 30 82 01 16 A0 ple.com....0.... 0050: 03 02 01 10 A1 03 02 01 03 A2 82 01 08 04 82 01 ................ 0060: 04 EC 1F C5 5C 81 86 A6 FB D0 8B 7F 90 45 87 20 ....\........E. 0070: 48 F1 31 88 3C 3C EC 8F 82 4D 29 98 60 F8 4A 0F H.1.<<...M).`.J. 0080: 9C 59 65 21 0E EB 32 C4 3A F8 A7 18 B8 A4 51 C2 .Ye!..2.:.....Q. 0090: 9E 3C 65 EC 39 6A 4F B4 48 1F D2 1D B5 67 78 0F .Z...... 00B0: E4 21 30 22 4B 4B 8B A9 D6 B0 BF 60 93 3E A4 35 .!0"KK.....`.>.5 00C0: E9 02 6E A7 EA 6A 83 BC 91 D6 1C 8F 24 F3 9D 79 ..n..j......$..y 00D0: 42 7E 0C B9 E0 29 D9 5A CF 37 6A F3 EC F0 31 CD B....).Z.7j...1. 00E0: 38 9D 69 2E A0 D1 43 21 0D 1A 1C 80 90 30 10 5D 8.i...C!.....0.] 00F0: 34 75 65 E7 32 59 8D 9D 54 D1 6F 56 60 D7 A0 00 4ue.2Y..T.oV`... 0100: 43 D6 D6 E6 E7 8D 3B B7 83 60 AF D7 03 73 43 9D C.....;..`...sC. 0110: 03 2D 23 90 A6 30 6C 09 27 6F 08 84 BA FC DE 1D .-#..0l.'o...... 0120: CF DE 17 FC F0 82 80 82 8D 68 3C D4 0D AB 72 35 .........h<...r5 0130: 25 99 68 40 5E 02 0F BE 01 3B 9F 92 CC 19 B4 C5 %.h@^....;...... 0140: 80 4A 23 F0 0D BE 65 8F 21 55 98 BD 67 4D 48 E1 .J#...e.!U..gMH. 0150: B3 C3 B8 CA 42 68 20 AE C4 36 E9 0F 0B 8A DC D4 ....Bh ..6...... 0160: 61 C6 E3 81 9D a.... Client Principal = kafka/kafka.example.com@EXAMPLE.COM Server Principal = zookeeper/kafka.example.com@EXAMPLE.COM Session Key = EncryptionKey: keyType=16 keyBytes (hex dump)= 0000: 8C DF 89 98 02 A4 E6 49 C2 6B 5E B0 01 DC C8 D9 .......I.k^..... 0010: 43 76 4A A8 7F 97 92 16 CvJ..... Forwardable Ticket true Forwarded Ticket false Proxiable Ticket false Proxy Ticket false Postdated Ticket false Renewable Ticket false Initial Ticket false Auth Time = Mon Apr 03 10:03:41 WEST 2017 Start Time = Mon Apr 03 10:03:41 WEST 2017 End Time = Mon Apr 03 20:03:41 WEST 2017 Renew Till = null Client Addresses Null >>> KrbApReq: APOptions are 00000000 00000000 00000000 00000000 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType Krb5Context setting mySeqNumber to: 1066216531 Krb5Context setting peerSeqNumber to: 0 Created InitSecContextToken: 0000: 01 00 6E 82 02 5D 30 82 02 59 A0 03 02 01 05 A1 ..n..]0..Y...... 0010: 03 02 01 0E A2 07 03 05 00 00 00 00 00 A3 82 01 ................ 0020: 65 61 82 01 61 30 82 01 5D A0 03 02 01 05 A1 0D ea..a0..]....... 0030: 1B 0B 45 58 41 4D 50 4C 45 2E 43 4F 4D A2 29 30 ..EXAMPLE.COM.)0 0040: 27 A0 03 02 01 00 A1 20 30 1E 1B 09 7A 6F 6F 6B '...... 0...zook 0050: 65 65 70 65 72 1B 11 6B 61 66 6B 61 2E 65 78 61 eeper..kafka.exa 0060: 6D 70 6C 65 2E 63 6F 6D A3 82 01 1A 30 82 01 16 mple.com....0... 0070: A0 03 02 01 10 A1 03 02 01 03 A2 82 01 08 04 82 ................ 0080: 01 04 EC 1F C5 5C 81 86 A6 FB D0 8B 7F 90 45 87 .....\........E. 0090: 20 48 F1 31 88 3C 3C EC 8F 82 4D 29 98 60 F8 4A H.1.<<...M).`.J 00A0: 0F 9C 59 65 21 0E EB 32 C4 3A F8 A7 18 B8 A4 51 ..Ye!..2.:.....Q 00B0: C2 9E 3C 65 EC 39 6A 4F B4 48 1F D2 1D B5 67 78 ..Z..... 00D0: DC E4 21 30 22 4B 4B 8B A9 D6 B0 BF 60 93 3E A4 ..!0"KK.....`.>. 00E0: 35 E9 02 6E A7 EA 6A 83 BC 91 D6 1C 8F 24 F3 9D 5..n..j......$.. 00F0: 79 42 7E 0C B9 E0 29 D9 5A CF 37 6A F3 EC F0 31 yB....).Z.7j...1 0100: CD 38 9D 69 2E A0 D1 43 21 0D 1A 1C 80 90 30 10 .8.i...C!.....0. 0110: 5D 34 75 65 E7 32 59 8D 9D 54 D1 6F 56 60 D7 A0 ]4ue.2Y..T.oV`.. 0120: 00 43 D6 D6 E6 E7 8D 3B B7 83 60 AF D7 03 73 43 .C.....;..`...sC 0130: 9D 03 2D 23 90 A6 30 6C 09 27 6F 08 84 BA FC DE ..-#..0l.'o..... 0140: 1D CF DE 17 FC F0 82 80 82 8D 68 3C D4 0D AB 72 ..........h<...r 0150: 35 25 99 68 40 5E 02 0F BE 01 3B 9F 92 CC 19 B4 5%.h@^....;..... 0160: C5 80 4A 23 F0 0D BE 65 8F 21 55 98 BD 67 4D 48 ..J#...e.!U..gMH 0170: E1 B3 C3 B8 CA 42 68 20 AE C4 36 E9 0F 0B 8A DC .....Bh ..6..... 0180: D4 61 C6 E3 81 9D A4 81 DA 30 81 D7 A0 03 02 01 .a.......0...... 0190: 10 A2 81 CF 04 81 CC 82 5E 82 F7 81 A2 2A F6 B9 ........^....*.. 01A0: 1A 18 48 6B 9F DE 79 D3 ED F3 79 61 0C F3 AD 31 ..Hk..y...ya...1 01B0: 93 89 00 A5 02 D0 CA 84 62 2E E5 BF FC BD DA BA ........b....... 01C0: 8F A7 EE 46 2A 56 68 B8 F3 1F 52 22 46 37 51 17 ...F*Vh...R"F7Q. 01D0: 3C 38 DC C3 69 DD 4F 45 CB BD B2 F9 B3 27 C3 9D <8..i.OE.....'.. 01E0: C1 26 D0 1D E3 0A C2 6B 3C 44 78 09 E6 B9 3B C8 .&.....k EndPoint(kafka.example.com,9092,SASL_PLAINTEXT) (kafka.utils.ZkUtils) [2017-04-03 10:03:42,276] INFO Kafka version : 0.10.1.1 (org.apache.kafka.common.utils.AppInfoParser) [2017-04-03 10:03:42,277] INFO Kafka commitId : f10ef2720b03b247 (org.apache.kafka.common.utils.AppInfoParser) [2017-04-03 10:03:42,277] INFO [Kafka Server 0], started (kafka.server.KafkaServer) Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Entered Krb5Context.initSecContext with state=STATE_NEW Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 Service ticket not found in the subject >>> Credentials acquireServiceCreds: same realm default etypes for default_tgs_enctypes: 16. Found KeyTab /etc/kafka/keytabs/kafka.keytab for kafka/kafka.example.com@EXAMPLE.COM Found ticket for kafka/kafka.example.com@EXAMPLE.COM to go to krbtgt/EXAMPLE.COM@EXAMPLE.COM expiring on Mon Apr 03 20:03:41 WEST 2017 >>> CksumType: sun.security.krb5.internal.crypto.RsaMd5CksumType >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbKdcReq send: kdc=kafka.example.com UDP:88, timeout=30000, number of retries =3, #bytes=688 >>> KDCCommunication: kdc=kafka.example.com UDP:88, timeout=30000,Attempt =1, #bytes=688 >>> KrbKdcReq send: #bytes read=698 >>> KdcAccessibility: remove kafka.example.com:88 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType >>> KrbApReq: APOptions are 00000000 00000000 00000000 00000000 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType Krb5Context setting mySeqNumber to: 531589022 Krb5Context setting peerSeqNumber to: 0 Created InitSecContextToken: 0000: 01 00 6E 82 02 69 30 82 02 65 A0 03 02 01 05 A1 ..n..i0..e...... 0010: 03 02 01 0E A2 07 03 05 00 00 00 00 00 A3 82 01 ................ 0020: 71 61 82 01 6D 30 82 01 69 A0 03 02 01 05 A1 0D qa..m0..i....... 0030: 1B 0B 45 58 41 4D 50 4C 45 2E 43 4F 4D A2 25 30 ..EXAMPLE.COM.%0 0040: 23 A0 03 02 01 00 A1 1C 30 1A 1B 05 6B 61 66 6B #.......0...kafk 0050: 61 1B 11 6B 61 66 6B 61 2E 65 78 61 6D 70 6C 65 a..kafka.example 0060: 2E 63 6F 6D A3 82 01 2A 30 82 01 26 A0 03 02 01 .com...*0..&.... 0070: 10 A1 03 02 01 03 A2 82 01 18 04 82 01 14 08 F0 ................ 0080: 0D 28 76 A3 1A C7 24 AC 16 E9 61 4E F3 7D 20 A8 .(v...$...aN.. . 0090: BF 86 1E CF 9F E4 F4 F1 6B 4A 95 1B 1E 17 6E 31 ........kJ....n1 00A0: 78 DE 43 67 DF D4 77 3A DB 7D C1 D3 4B 61 A6 82 x.Cg..w:....Ka.. 00B0: 31 EE FA 87 27 B8 F4 5D 9F 8C 1D 6E D8 19 F0 34 1...'..]...n...4 00C0: B5 24 7B 3D 85 37 F8 2D 28 CF 55 18 AD 5F 73 BF .$.=.7.-(.U.._s. 00D0: B7 CF AC 55 1D 96 11 F1 F0 56 9C C8 29 1D BE 28 ...U.....V..)..( 00E0: 2A 4D 8F 0D 03 63 BB 71 BB 49 53 E7 6D A1 8F C0 *M...c.q.IS.m... 00F0: EE 85 9D F4 84 08 B0 3F A0 02 51 4A 47 AA 08 0C .......?..QJG... 0100: 64 46 22 78 5A 4F A6 66 75 23 0C 3F 9E 37 06 F0 dF"xZO.fu#.?.7.. 0110: 93 50 08 25 EA 47 7E F9 59 D1 58 A7 D3 11 57 59 .P.%.G..Y.X...WY 0120: 55 D6 21 18 74 98 EA 51 95 A1 68 43 DD C9 23 26 U.!.t..Q..hC..#& 0130: D4 5C 0E D0 E0 E1 F0 04 5C EF ED AC 17 43 09 50 .\......\....C.P 0140: A3 15 3B B0 A7 F2 9F 2F 4E 74 54 77 7F 95 C6 01 ..;..../NtTw.... 0150: 05 E3 EF 84 AC 17 9B 7E 09 17 BD 6B 78 B9 9A 49 ...........kx..I 0160: 6C 61 07 DA C7 26 14 30 49 51 29 16 A6 74 B6 D8 la...&.0IQ)..t.. 0170: 04 D3 DE 71 1B E1 81 D6 64 37 50 18 52 4D 7B AE ...q....d7P.RM.. 0180: 01 59 7C 51 A4 77 48 93 ED 68 8E 86 0B A3 26 6D .Y.Q.wH..h....&m 0190: 67 D3 A4 81 DA 30 81 D7 A0 03 02 01 10 A2 81 CF g....0.......... 01A0: 04 81 CC F4 46 C0 AE 09 53 71 4A 0C 79 DC 42 ED ....F...SqJ.y.B. 01B0: 8B 10 C4 E1 8A 53 FB 23 92 23 85 5D 21 79 A3 59 .....S.#.#.]!y.Y 01C0: 24 01 E4 1E FA 5D 5E 80 5A 19 9E 66 6E 06 C3 E7 $....]^.Z..fn... 01D0: 89 20 72 85 6B 2B D0 FE 2C 0F B4 8A EE 4A E2 7A . r.k+..,....J.z 01E0: 62 E2 79 3A A8 8A BD B0 C8 74 46 15 EC E8 79 3D b.y:.....tF...y= 01F0: B6 FE 2D 81 B7 32 48 6C 4C E2 A8 62 AD AD 1B 91 ..-..2HlL..b.... 0200: 86 C8 87 1F 19 2C 0A DD EA 07 F6 DA 9F 34 54 30 .....,.......4T0 0210: B5 8A 17 4C 14 49 F3 CB FE 17 BF 39 F5 90 C2 57 ...L.I.....9...W 0220: BA 77 EC 27 75 F3 C3 46 C6 D3 72 B9 4F F6 A5 45 .w.'u..F..r.O..E 0230: 2B 48 77 8C A1 43 92 8C BB 33 50 4D D7 76 5D 8A +Hw..C...3PM.v]. 0240: C5 23 2A C9 5C D8 14 DB 93 A4 7D 41 80 C3 A4 BB .#*.\......A.... 0250: AC ED 4D FB 28 C6 D8 6A 5E 97 B0 F1 CE 69 67 23 ..M.(..j^....ig# 0260: 8A 41 F8 6C DF FE 2B C1 D3 1F 5E 5F 10 4E B2 .A.l..+...^_.N. Entered Krb5Context.acceptSecContext with state=STATE_NEW Looking for keys for: kafka/kafka.example.com@EXAMPLE.COM Added key: 16version: 3 >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType default etypes for permitted_enctypes: 16. >>> EType: sun.security.krb5.internal.crypto.Des3CbcHmacSha1KdEType MemoryCache: add 1491210222/344189/92B1DB3E32F14859657CD17141BFFDA7/kafka/kafka.example.com@EXAMPLE.COM to kafka/kafka.example.com@EXAMPLE.COM|kafka/kafka.example.com@EXAMPLE.COM >>> KrbApReq: authenticate succeed. Krb5Context setting peerSeqNumber to: 531589022 Krb5Context setting mySeqNumber to: 531589022 Krb5Context.wrap: data=[01 01 00 00 ] Krb5Context.wrap: token=[60 3f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 21 21 e3 13 ca aa dd f9 a9 44 48 58 a6 ae 53 db fc f8 65 ca fa 59 3a da 05 7b 3d 30 e5 65 82 a6 8b dc 00 9e 01 01 00 00 04 04 04 04 ] Krb5Context.unwrap: token=[60 3f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 21 21 e3 13 ca aa dd f9 a9 44 48 58 a6 ae 53 db fc f8 65 ca fa 59 3a da 05 7b 3d 30 e5 65 82 a6 8b dc 00 9e 01 01 00 00 04 04 04 04 ] Krb5Context.unwrap: data=[01 01 00 00 ] Krb5Context.wrap: data=[01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d ] Krb5Context.wrap: token=[60 5f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 51 29 b8 4c 16 f4 d8 be 64 8d 6c 94 b5 97 da a3 d7 16 07 86 09 18 ec d0 78 25 a4 f2 0f eb 10 94 a2 e4 dc 52 01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d 01 ] Krb5Context.unwrap: token=[60 5f 06 09 2a 86 48 86 f7 12 01 02 02 02 01 04 00 ff ff ff ff 51 29 b8 4c 16 f4 d8 be 64 8d 6c 94 b5 97 da a3 d7 16 07 86 09 18 ec d0 78 25 a4 f2 0f eb 10 94 a2 e4 dc 52 01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d 01 ] Krb5Context.unwrap: data=[01 01 00 00 6b 61 66 6b 61 2f 6b 61 66 6b 61 2e 65 78 61 6d 70 6c 65 2e 63 6f 6d 40 45 58 41 4d 50 4c 45 2e 43 4f 4d ] [2017-04-03 10:03:42,358] INFO Successfully authenticated client: authenticationID=kafka/kafka.example.com@EXAMPLE.COM; authorizationID=kafka/kafka.example.com@EXAMPLE.COM. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler) [2017-04-03 10:03:42,358] INFO Setting authorizedID: kafka (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)