[jira] [Created] (KAFKA-1882) Create extendable channel interface and default implementations

["Gwen Shapira (JIRA)" <ji...@apache.org>]

Gwen Shapira created KAFKA-1882:
-----------------------------------

             Summary: Create extendable channel interface and default implementations
                 Key: KAFKA-1882
                 URL: https://issues.apache.org/jira/browse/KAFKA-1882
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Gwen Shapira
            Assignee: Gwen Shapira


For the security infrastructure, we need an extendible interface to replace SocketChannel.

KAFKA-1684 suggests extending SocketChannel itself, but since SocketChannel is part of Java's standard library, the interface changes between different Java versions, so extending it directly can become a compatibility issue.

Instead, we can implement a KafkaChannel interface, which will implement connect(), read(), write() and possibly other methods we use. 

We will replace direct use of SocketChannel in our code with use of KafkaChannel.

Different implementations of KafkaChannel will be instantiated based on the port/SecurityProtocol configuration. 

This patch will provide at least the PLAINTEXT implementation for KafkaChannel.

I will validate that the SSL implementation in KAFKA-1684 can be refactored to use a KafkaChannel interface rather than extend SocketChannel directly. However, the patch will not include the SSL channel itself.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)