[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711100#comment-14711100
]
Navjot edited comment on KAFKA-1690 at 8/25/15 2:15 PM:
--------------------------------------------------------
[~harsha_ch]Please find the java version below:
{{java version "1.7.0_79"}}
{{Java(TM) SE Runtime Environment (build 1.7.0_79-b15)}}
{{Java HotSpot(TM) 64-Bit Server VM (build 24.79-b02, mixed mode)}}
I am working on Windows 7 64bit machine.
Also, I tried to use the package by following steps mentioned at
[https://github.com/harshach/kafka/blob/KAFKA-1690-V1/SSL-setup.md]
but my Server and Producer failed with following errors:
{{################# Producer Error
##############################################}}
{{[2015-08-25 16:00:21,888] WARN Failed to send SSL Close}}
{{message(org.apache.kafka.common.network.SSLTransportLayer)}}
{{java.io.IOException: Invalid close state, will not send network data.}}
{{at
org.apache.kafka.common.network.SSLTransportLayer.close(SSLTransportLayer.java:144)}}
{{at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:49)}}
{{at org.apache.kafka.common.network.Selector.close(Selector.java:458)}}
{{at org.apache.kafka.common.network.Selector.poll(Selector.java:327)}}
{{at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:221)}}
{{at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:209)}}
{{at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:127)}}
{{at java.lang.Thread.run(Thread.java:745)}}
{{################ Server Error
##################################################}}
{{[2015-08-25 15:59:22,572] WARN Error when freeing index buffer
(kafka.log.OffsetIndex)}}
{{java.lang.NullPointerException}}
{{at
kafka.log.OffsetIndex.kafka$log$OffsetIndex$$forceUnmap(OffsetIndex.scala:301)}}
{{at kafka.log.OffsetIndex$$anonfun$resize$1.apply(OffsetIndex.scala:283)}}
{{at kafka.log.OffsetIndex$$anonfun$resize$1.apply(OffsetIndex.scala:276)}}
{{at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)}}
{{at kafka.log.OffsetIndex.resize(OffsetIndex.scala:276)}}
{{at kafka.log.Log.loadSegments(Log.scala:234)}}
{{at kafka.log.Log.<init>(Log.scala:90)}}
{{at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$3$$anonfun}}
{{$apply$10$$anonfun$apply$1.apply$mcV$sp(LogManager.scala:150)}}
{{at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:60)}}
{{at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)}}
{{at java.util.concurrent.FutureTask.run(FutureTask.java:262)}}
{{at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)}}
{{at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)}}
{{at java.lang.Thread.run(Thread.java:745)}}
Also while running producer I can see following WARNS:
kafka-console-producer.bat --broker-list localhost:9093 --topic test1
--new-producer --producer-property "security.protocol=SSL" --producer-property
"ssl.truststore.location=client.truststore.jks" --producer-property
"ssl.truststore.password=striker"
[2015-08-25 18:20:48,236] WARN The configuration ssl.truststore.location =
C:\Users\g01013268\Desktop\Certs\client.truststore.jks was supplied but isn't a
known config. (org.apache.kafka.clients.producer.ProducerConfig)
[2015-08-25 18:20:48,236] WARN The configuration ssl.truststore.password =
striker was supplied but isn't a known config.
(org.apache.kafka.clients.producer.ProducerConfig)
[2015-08-25 18:20:48,236] WARN The configuration security.protocol = SSL was
supplied but isn't a known config.
(org.apache.kafka.clients.producer.ProducerConfig)
was (Author: navjotbhardwaj):
[~harsha_ch]Please find the java version below:
{{java version "1.7.0_79"}}
{{Java(TM) SE Runtime Environment (build 1.7.0_79-b15)}}
{{Java HotSpot(TM) 64-Bit Server VM (build 24.79-b02, mixed mode)}}
I am working on Windows 7 64bit machine.
Also, I tried to use the package by following steps mentioned at
[https://github.com/harshach/kafka/blob/KAFKA-1690-V1/SSL-setup.md]
but my Server and Producer failed with following errors:
{{################# Producer Error
##############################################}}
{{[2015-08-25 16:00:21,888] WARN Failed to send SSL Close}}
{{message(org.apache.kafka.common.network.SSLTransportLayer)}}
{{java.io.IOException: Invalid close state, will not send network data.}}
{{at
org.apache.kafka.common.network.SSLTransportLayer.close(SSLTransportLayer.java:144)}}
{{at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:49)}}
{{at org.apache.kafka.common.network.Selector.close(Selector.java:458)}}
{{at org.apache.kafka.common.network.Selector.poll(Selector.java:327)}}
{{at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:221)}}
{{at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:209)}}
{{at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:127)}}
{{at java.lang.Thread.run(Thread.java:745)}}
{{################ Server Error
##################################################}}
{{[2015-08-25 15:59:22,572] WARN Error when freeing index buffer
(kafka.log.OffsetIndex)}}
{{java.lang.NullPointerException}}
{{at
kafka.log.OffsetIndex.kafka$log$OffsetIndex$$forceUnmap(OffsetIndex.scala:301)}}
{{at kafka.log.OffsetIndex$$anonfun$resize$1.apply(OffsetIndex.scala:283)}}
{{at kafka.log.OffsetIndex$$anonfun$resize$1.apply(OffsetIndex.scala:276)}}
{{at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)}}
{{at kafka.log.OffsetIndex.resize(OffsetIndex.scala:276)}}
{{at kafka.log.Log.loadSegments(Log.scala:234)}}
{{at kafka.log.Log.<init>(Log.scala:90)}}
{{at kafka.log.LogManager$$anonfun$loadLogs$2$$anonfun$3$$anonfun}}
{{$apply$10$$anonfun$apply$1.apply$mcV$sp(LogManager.scala:150)}}
{{at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:60)}}
{{at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)}}
{{at java.util.concurrent.FutureTask.run(FutureTask.java:262)}}
{{at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)}}
{{at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)}}
{{at java.lang.Thread.run(Thread.java:745)}}
> Add SSL support to Kafka Broker, Producer and Consumer
> ------------------------------------------------------
>
> Key: KAFKA-1690
> URL: https://issues.apache.org/jira/browse/KAFKA-1690
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Joe Stein
> Assignee: Sriharsha Chintalapani
> Fix For: 0.8.3
>
> Attachments: KAFKA-1690.patch, KAFKA-1690.patch,
> KAFKA-1690_2015-05-10_23:20:30.patch, KAFKA-1690_2015-05-10_23:31:42.patch,
> KAFKA-1690_2015-05-11_16:09:36.patch, KAFKA-1690_2015-05-12_16:20:08.patch,
> KAFKA-1690_2015-05-15_07:18:21.patch, KAFKA-1690_2015-05-20_14:54:35.patch,
> KAFKA-1690_2015-05-21_10:37:08.patch, KAFKA-1690_2015-06-03_18:52:29.patch,
> KAFKA-1690_2015-06-23_13:18:20.patch, KAFKA-1690_2015-07-20_06:10:42.patch,
> KAFKA-1690_2015-07-20_11:59:57.patch, KAFKA-1690_2015-07-25_12:10:55.patch,
> KAFKA-1690_2015-08-16_20:41:02.patch, KAFKA-1690_2015-08-17_08:12:50.patch,
> KAFKA-1690_2015-08-17_09:28:52.patch, KAFKA-1690_2015-08-17_12:20:53.patch,
> KAFKA-1690_2015-08-18_11:24:46.patch, KAFKA-1690_2015-08-18_17:24:48.patch
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
