VOL-2708 prevent deadlock during timeout in invokerpc
Change-Id: I5ee6ea7193d344f841f9afd2085cf3719e5ee744
diff --git a/VERSION b/VERSION
index d19cf84..29cec99 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-3.0.17
+3.0.18
diff --git a/pkg/kafka/kafka_inter_container_library.go b/pkg/kafka/kafka_inter_container_library.go
index 91b2143..c7dc5af 100644
--- a/pkg/kafka/kafka_inter_container_library.go
+++ b/pkg/kafka/kafka_inter_container_library.go
@@ -799,7 +799,8 @@
// Create a specific channel for this consumers. We cannot use the channel from the kafkaclient as it will
// broadcast any message for this topic to all channels waiting on it.
- ch := make(chan *ic.InterContainerMessage)
+ // Set channel size to 1 to prevent deadlock, see VOL-2708
+ ch := make(chan *ic.InterContainerMessage, 1)
kp.addToTransactionIdToChannelMap(trnsId, &topic, ch)
return ch, nil