메뉴 건너뛰기

검색창 닫기

Bigdata, Semantic IoT, Hadoop, NoSQL

Bigdata, Hadoop ecosystem, Semantic IoT등의 프로젝트를 진행중에 습득한 내용을 정리하는 곳입니다.
필요한 분을 위해서 공개하고 있습니다. 문의사항은 gooper@gooper.com로 메일을 보내주세요.


kafka 운영중인 상태에서 kafka topic삭제하고 재생성하여 처리되지 않은 메세지 모두 삭제하기

총관리자 2016.10.24 11:06 조회 수 : 156

1. kafka broker의 server.properties파일에 다음 옵션을 설정하고 broker를 재기동한다.
delete.topic.enable=true

2. 다음의 명령으로 원하는 topic(예, test)을 삭제한다.
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test

3. topic을 재생성한다.
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test

4. topic을 지우고 재생성한 상태에서 consumer프로그램을 돌리면 아래와 같은 오류가 발생하면서 재설정된다.

------오류내용-------------
[2016-10-24 10:43:12,735] [utils.Logging$class] [error(#97)] [ERROR] [ConsumerFetcherThread-AvroOneM2MDataSubscribe_sda1-1477273392365-4e4cbb22-0-1], Current offset 109883 for partition [COL_ONEM2M,1] out of range; r
eset offset to 0
[2016-10-24 10:43:12,735] [utils.Logging$class] [error(#97)] [ERROR] [ConsumerFetcherThread-AvroOneM2MDataSubscribe_sda1-1477273392365-4e4cbb22-0-3], Current offset 127067 for partition [COL_ONEM2M,0] out of range; r
eset offset to 0
[2016-10-24 10:43:12,735] [utils.Logging$class] [error(#97)] [ERROR] [ConsumerFetcherThread-AvroOneM2MDataSubscribe_sda1-1477273392365-4e4cbb22-0-2], Current offset 116344 for partition [COL_ONEM2M,2] out of range; r
eset offset to 0
이 게시물을
목록
번호 제목 글쓴이 날짜 조회 수
» 운영중인 상태에서 kafka topic삭제하고 재생성하여 처리되지 않은 메세지 모두 삭제하기 총관리자 2016.10.24 156
300 format된 namenode를 다른 서버에서 다시 format했을때 오류내용 총관리자 2016.09.22 155
299 [CentOS] 네트워크 설정 총관리자 2018.03.26 154
298 spark 시동중 applicationHistory 로그 디렉토리가 없다고 하면서 기동되지 않는 경우 총관리자 2018.06.01 153
297 schema.xml vs managed-schema 지정 사용하기 - 두개를 동시에 사용할 수는 없음 총관리자 2017.07.09 153
296 test2 총관리자 2017.05.01 153
295 windows7에서 lagom의 hello world를 빌드하여 실행하는 경우의 로그(mvn lagom:runAll -Dscala.binary.version=2.11) 총관리자 2017.12.22 152
294 [PHP7.0]로그파일 위치 총관리자 2017.05.07 151
293 No broker partitions consumed by consumer thread오류 발생시 확인/조치할 사항 총관리자 2016.09.02 151
292 [HIVESERVER2]프로세스의 thread및 stack trace를 덤프하는 방법(pstack, jstack) 총관리자 2022.05.11 150
291 천문학적, 기후학적, 기상학적, 생물학적, 농사계절 구분 총관리자 2015.12.16 150
290 이미지 관리 오픈소스 목록 총관리자 2018.03.11 149
289 Cloudera의 API를 이용하여 impala의 실행되었던 쿼리 확인하는 예시 총관리자 2018.05.03 148
288 magento2 2.1.3을 수동으로 설치하는 방법 총관리자 2017.02.01 148
287 Apache Toree설치(Jupyter에서 Scala, PySpark, SparkR, SQL을 사용할 수 있도록 하는 Kernel) 총관리자 2018.04.17 146
286 [jsoup]Jsoup Tutorial 총관리자 2017.04.11 146
285 update(update와 delete->insert)사용시 주의/참고사항 총관리자 2016.01.06 146
284 mongodb에서 큰데이타 sort시 오류발생에 대한 해결방법 총관리자 2015.12.22 145
283 ?a는 모두 표시하면서 ?b와 비교하여 ?a=?b는 ""로 하고 ?a!=?b 인경우는 해당값을 가지는 결과 집합을 구하는 경우 file 총관리자 2016.01.29 144
282 LUBM 데이타 생성구문 총관리자 2017.07.24 143
쓰기 태그

A personal place to organize information learned during the development of such Hadoop, Hive, Hbase, Semantic IoT, etc.
We are open to the required minutes. Please send inquiries to gooper@gooper.com.

위로