Permalink
Browse files

Kafka-12, cont. Update one more call to disconnect.

  • Loading branch information...
jghoman committed Dec 22, 2010
1 parent 8cd5004 commit 4f34fcf173da1e57571a4630826ddab97d23b784
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/kafka/producer/KafkaProducer.scala
@@ -132,7 +132,7 @@ class SimpleProducer(val host: String,
}
catch {
case e: Exception => {
- disconnect(channel)
+ disconnect()
val endTimeMs = SystemTime.milliseconds
if ( (endTimeMs - beginTimeMs + connectBackoffMs) > connectTimeoutMs)
{

0 comments on commit 4f34fcf

Please sign in to comment.