NewConn returns a new kafka connection for the given topic and partition.
(conn net.Conn, topic string, partition int)
| 146 | |
| 147 | // NewConn returns a new kafka connection for the given topic and partition. |
| 148 | func NewConn(conn net.Conn, topic string, partition int) *Conn { |
| 149 | return NewConnWith(conn, ConnConfig{ |
| 150 | Topic: topic, |
| 151 | Partition: partition, |
| 152 | }) |
| 153 | } |
| 154 | |
| 155 | func emptyToNullable(transactionalID string) (result *string) { |
| 156 | if transactionalID != "" { |