Fix lint errors (#709)

* fix lint errors

* restore permissions

pkg/source/adapter/adapter.go

@@ -67,10 +67,9 @@ func NewEnvConfig() adapter.EnvConfigAccessor {
 }
 
 type Adapter struct {
- config *AdapterConfig
- controlServer *ctrlnetwork.ControlServer
- saramaConfig *sarama.Config
- offsetInitialized bool
+ config *AdapterConfig
+ controlServer *ctrlnetwork.ControlServer
+ saramaConfig *sarama.Config
 
  httpMessageSender *kncloudevents.HTTPMessageSender
  reporter pkgsource.StatsReporter

pkg/source/adapter/adapter_test.go

@@ -442,64 +442,3 @@ func TestAdapter_Start(t *testing.T) { // just increase code coverage
  }
  cancel()
 }
-
-type sampleConsumerSession struct {
- offsets map[string]map[int32]int64
- committed bool
-}
-
-func (s *sampleConsumerSession) Claims() map[string][]int32 {
- return nil
-}
-
-func (s *sampleConsumerSession) MemberID() string {
- return ""
-}
-
-func (s *sampleConsumerSession) GenerationID() int32 {
- return int32(0)
-}
-
-func (s *sampleConsumerSession) GetOffset(topic string, partition int32) int64 {
- if s.offsets == nil {
- return -2
- }
- partitions, ok := s.offsets[topic]
- if !ok {
- return -2
- }
- offset, ok := partitions[partition]
- if !ok {
- return -2
- }
- return offset
-}
-
-func (s *sampleConsumerSession) MarkOffset(topic string, partition int32, offset int64, metadata string) {
- if s.offsets == nil {
- s.offsets = make(map[string]map[int32]int64)
- }
-
- partitions, ok := s.offsets[topic]
- if !ok {
- partitions = make(map[int32]int64)
- s.offsets[topic] = partitions
- }
- partitions[partition] = offset
-}
-
-func (s *sampleConsumerSession) Commit() {
- s.committed = true
-}
-
-func (s *sampleConsumerSession) ResetOffset(topic string, partition int32, offset int64, metadata string) {
-
-}
-
-func (s *sampleConsumerSession) MarkMessage(msg *sarama.ConsumerMessage, metadata string) {
-
-}
-
-func (s *sampleConsumerSession) Context() context.Context {
- return nil
-}